lib/filbunke/client.rb in filbunke-1.7.2 vs lib/filbunke/client.rb in filbunke-1.7.3
- old
+ new
@@ -120,11 +120,11 @@
def update_file!(file, local_file_path)
if file.url =~ /^http:\/\//
update_http_file!(file, local_file_path)
elsif file.url =~ /^hdfs:\/\//
- update_hdfs_file!(file, local_file_path)
- run_callbacks(file)
+ success = update_hdfs_file!(file, local_file_path)
+ run_callbacks(file, local_file_path) if success
else
raise "Unsupported protocol for file: #{file.inspect}"
end
end