class SimplerWorkflow::Workflow::ActivityTaskTimedOutHandler
Public Instance Methods
call(decision_task, event)
click to toggle source
# File lib/simpler_workflow/workflow.rb, line 191 def call(decision_task, event) case event.attributes.timeoutType when 'START_TO_CLOSE', 'SCHEDULE_TO_START', 'SCHEDULE_TO_CLOSE' last_activity_type = last_activity(decision_task, event) SimplerWorkflow.logger.info("Retrying activity #{last_activity_type.name} #{last_activity_type.version} due to timeout.") decision_task.schedule_activity_task last_activity_type, :input => last_input(decision_task, event) when 'HEARTBEAT' decision_task.fail_workflow_execution end end