Sha256: 30528ba6ea32366a49f38ce4c5531a3cd554357008cfa682b782fd9675791a21
Contents?: true
Size: 1.12 KB
Versions: 15
Compression:
Stored size: 1.12 KB
Contents
module MotherBrain
class CommandInvoker
class Worker
include Celluloid
# @return [MB::Command]
attr_reader :command
# @return [String]
attr_reader :environment
# @return [Array]
attr_reader :node_filter
# @param [MB::Command] command
# command to invoke
# @param [String] environment
# environment to invoke this command on
# @param [Array] node_filter = nil
# list of nodes to limit the command to
def initialize(command, environment, node_filter = nil)
@command = command
@environment = environment
@node_filter = node_filter
end
# @param [MB::Job] job
# @param [Array] arguments
def run(job, arguments = Array.new)
arguments ||= Array.new
msg = "Invoking #{command.type} command #{command.scope.name} #{command.name} on #{environment}"
msg << " with arguments: #{arguments}" if arguments.any?
job.set_status(msg)
command.invoke(job, environment, node_filter, *arguments)
rescue RemoteCommandError => ex
abort(ex)
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems