Sha256: 05760ff744727f3524fc943184f92cab15a18862f6c77980141819932fc37371
Contents?: true
Size: 1.03 KB
Versions: 12
Compression:
Stored size: 1.03 KB
Contents
module Actions
module RecurringAction
# When included sets the base action to use the RecurringLogic middleware and configures
# #trigger_repeat to be called when appropriate to trigger the next repeat.
def self.included(base)
base.middleware.use Actions::Middleware::RecurringLogic
base.execution_plan_hooks.use :trigger_repeat, :on => [:planned, :failure]
end
# Hook to be called when a repetition needs to be triggered. This either happens when the plan goes into planned state
# or when it fails.
def trigger_repeat(execution_plan)
if execution_plan.delay_record && recurring_logic_task_group
args = execution_plan.delay_record.args
logic = recurring_logic_task_group.recurring_logic
logic.trigger_repeat_after(task.start_at, self.class, *args)
end
end
private
def recurring_logic_task_group
@task_group ||= task.task_groups
.find { |tg| tg.is_a? ::ForemanTasks::TaskGroups::RecurringLogicTaskGroup }
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems