Sha256: cb3898ea75e2fc9d155446fef5b8d18fb03e42a722bcb1ec463fe35d9aaf5f00
Contents?: true
Size: 835 Bytes
Versions: 158
Compression:
Stored size: 835 Bytes
Contents
module Actions module Middleware class BindJobInvocation < ::Dynflow::Middleware def delay(*args) schedule_options, job_invocation = args if !job_invocation.task_id.nil? && job_invocation.task_id != task.id job_invocation = job_invocation.deep_clone! args = [schedule_options, job_invocation] end pass(*args).tap { bind(job_invocation) } end def plan(*args) job_invocation = args.first pass(*args).tap { bind(job_invocation) } end private def task @task ||= ForemanTasks::Task::DynflowTask.where(:external_id => action.execution_plan_id).first! end def bind(job_invocation) job_invocation.update_attribute :task_id, task.id if job_invocation.task_id != task.id end end end end
Version data entries
158 entries across 158 versions & 1 rubygems