Class: Airflow::Handlers::CompleteTaskCommandHandler
- Inherits:
-
Object
- Object
- Airflow::Handlers::CompleteTaskCommandHandler
- Defined in:
- lib/async_flow/handlers.rb
Instance Method Summary collapse
Instance Method Details
#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 |