Method: Airflow::Handlers::CompleteTaskCommandHandler#call

Defined in:
lib/async_flow/handlers.rb

#call(cmd) ⇒ Object 



19
20
21
22
23
 
# File 'lib/async_flow/handlers.rb', line 19

def call(cmd)
  run = Persistence.workflow_runs.find_run_by_task_id(cmd.task_id)
  run.complete_task(cmd.task_id, cmd.result)
  Persistence.workflow_runs.save!(run)
end