Sha256: 8b1a071c837aaa9cbecad5025fd9a55ac01536af6e36b08a907f4b9f6b260b29
Contents?: true
Size: 1.79 KB
Versions: 13
Compression:
Stored size: 1.79 KB
Contents
module Actions
class Base < Dynflow::Action
def task
@task ||= ::ForemanTasks::Task::DynflowTask.find_by_external_id!(execution_plan_id)
end
# This method says what data form input gets into the task details in Rest API
# By default, it sends the whole input there.
def task_input
self.input
end
# This method says what data form output gets into the task details in Rest API
# It should aggregate the important data that are worth to propagate to Rest API,
# perhaps also aggraget data from subactions if needed (using +all_actions+) method
# of Dynflow::Action::Presenter
def task_output
self.output
end
# This method should return humanized description of the action, e.g. "Install package"
def humanized_name
self.class.name.demodulize.underscore.humanize
end
# This method should return String or Array<String> describing input for the task
def humanized_input
if task_input.blank?
""
else
task_input.pretty_inspect
end
end
# This method should return String describing output for the task.
# It should aggregate the data from subactions as well and it's used for humanized
# description of restuls of the action
def humanized_output
if task_output.blank?
""
else
task_output.pretty_inspect
end
end
# This method should return String or Array<String> describing the errors during the action
def humanized_errors
execution_plan.steps_in_state(:skipped, :skipping, :error).map do |step|
step.error.message if step.error
end.compact
end
def already_running?
ForemanTasks::Task::DynflowTask.for_action(self.class).
running.where('external_id != ?', execution_plan_id).any?
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems