lib/bolt/transport/base.rb in bolt-1.32.0 vs lib/bolt/transport/base.rb in bolt-1.33.0
- old
+ new
@@ -123,11 +123,11 @@
# Transports may override this method to implement their own batch processing.
def batch_task(targets, task, arguments, options = {}, &callback)
assert_batch_size_one("batch_task()", targets)
target = targets.first
with_events(target, callback) do
- @logger.debug { "Running task run '#{task}' on #{target.uri}" }
+ @logger.debug { "Running task run '#{task}' on #{target.safe_name}" }
run_task(target, task, arguments, options)
end
end
# Runs the given command on a batch of nodes.
@@ -137,11 +137,11 @@
# Transports may override this method to implement their own batch processing.
def batch_command(targets, command, options = {}, &callback)
assert_batch_size_one("batch_command()", targets)
target = targets.first
with_events(target, callback) do
- @logger.debug("Running command '#{command}' on #{target.uri}")
+ @logger.debug("Running command '#{command}' on #{target.safe_name}")
run_command(target, command, options)
end
end
# Runs the given script on a batch of nodes.
@@ -151,11 +151,11 @@
# Transports may override this method to implement their own batch processing.
def batch_script(targets, script, arguments, options = {}, &callback)
assert_batch_size_one("batch_script()", targets)
target = targets.first
with_events(target, callback) do
- @logger.debug { "Running script '#{script}' on #{target.uri}" }
+ @logger.debug { "Running script '#{script}' on #{target.safe_name}" }
run_script(target, script, arguments, options)
end
end
# Uploads the given source file to the destination location on a batch of nodes.
@@ -165,10 +165,10 @@
# Transports may override this method to implement their own batch processing.
def batch_upload(targets, source, destination, options = {}, &callback)
assert_batch_size_one("batch_upload()", targets)
target = targets.first
with_events(target, callback) do
- @logger.debug { "Uploading: '#{source}' to #{destination} on #{target.uri}" }
+ @logger.debug { "Uploading: '#{source}' to #{destination} on #{target.safe_name}" }
upload(target, source, destination, options)
end
end
def batch_connected?(targets)