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