Class: Airflow::Handlers::StartWorkflowHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/async_flow/handlers.rb

Instance Method Summary collapse

Instance Method Details

#call(cmd) ⇒ Object 



8
9
10
11
12
13
14
15
 
# File 'lib/async_flow/handlers.rb', line 8

def call(cmd)
  run = Models::WorkflowRun.new(
    workflow_id: cmd.workflow_id,
    workflow_name: cmd.workflow_name
  )
  run.start
  Persistence.workflow_runs.create!(run)
end