class ForemanTasks::Dynflow::Persistence
Wrap the Dynflow persistence to reflect the changes to execution plan in the Task model. This is probably a temporary solution and Dynflow will probably get more events-based API but it should be enought for start, until the requiements on the API are clear enough.
Public Instance Methods
on_execution_plan_save(execution_plan_id, data)
click to toggle source
# File lib/foreman_tasks/dynflow/persistence.rb, line 20 def on_execution_plan_save(execution_plan_id, data) # We can load the data unless the execution plan was properly planned and saved # including its steps case data[:state] when :pending task = ForemanTasks::Task::DynflowTask.new_for_execution_plan(execution_plan_id, data) task.start_at ||= Time.zone.now task.save! when :scheduled delayed_plan = load_delayed_plan(execution_plan_id) raise Foreman::Exception, 'Plan is delayed but the delay record is missing' if delayed_plan.nil? task = ::ForemanTasks::Task::DynflowTask.find_by!(:external_id => execution_plan_id) task.update_from_dynflow(data.merge(:start_at => delayed_plan[:start_at], :start_before => delayed_plan[:start_before])) when :planning task = ::ForemanTasks::Task::DynflowTask.where(:external_id => execution_plan_id).first task.update_from_dynflow(data) else if (task = ::ForemanTasks::Task::DynflowTask.where(:external_id => execution_plan_id).first) unless task.state.to_s == data[:state].to_s task.update_from_dynflow(data) end end end end
save_execution_plan(execution_plan_id, value)
click to toggle source
Calls superclass method
# File lib/foreman_tasks/dynflow/persistence.rb, line 7 def save_execution_plan(execution_plan_id, value) # clear connection only if not running in some active record transaction already clear_connections = ActiveRecord::Base.connection.open_transactions.zero? super.tap do on_execution_plan_save(execution_plan_id, value) rescue => e Foreman::Logging.exception('Error on on_execution_plan_save event', e, :logger => 'dynflow') end ensure ::ActiveRecord::Base.clear_active_connections! if clear_connections end