Sha256: c580d202ab24554fc30a48aae51d2c59732df45e53f9a726b87a80007c551a4c
Contents?: true
Size: 1.99 KB
Versions: 13
Compression:
Stored size: 1.99 KB
Contents
module Actions
class Base < Dynflow::Action
middleware.use ::Actions::Middleware::RailsExecutorWrap if Rails::VERSION::MAJOR > 4
def task
@task ||= ::ForemanTasks::Task::DynflowTask.where(:external_id => execution_plan_id).first!
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
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
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
def serializer_class
::Actions::Serializers::ActiveRecordSerializer
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems