class SimplerWorkflow::Workflow::ActivityTaskCompletedHandler
Public Instance Methods
call(decision_task, event)
click to toggle source
# File lib/simpler_workflow/workflow.rb, line 223 def call(decision_task, event) last_activity_type = last_activity(decision_task, event) completed_activity = domain.activities[last_activity_type] if next_activity = completed_activity.next_activity activity_type = domain.activity_types[next_activity.name, next_activity.version] decision_task.schedule_activity_task activity_type, input: scheduled_event(decision_task, event).attributes.input else decision_task.complete_workflow_execution(result: 'success') end end