lib/aerospike/client.rb in aerospike-2.10.0 vs lib/aerospike/client.rb in aerospike-2.11.0
- old
+ new
@@ -524,10 +524,10 @@
nodes = @cluster.nodes
if nodes.empty?
raise Aerospike::Exceptions::Aerospike.new(Aerospike::ResultCode::SERVER_NOT_AVAILABLE, "Executing UDF failed because cluster is empty.")
end
- # TODO: wait until all migrations are finished
+ statement = statement.clone
statement.set_aggregate_function(package_name, function_name, function_args, false)
# Use a thread per node
nodes.each do |node|
Thread.new do