Method: Airflow::Client#workflow_info

Defined in:
lib/async_flow/client.rb

#workflow_info(workflow_id) ⇒ Object 



37
38
39
40
 
# File 'lib/async_flow/client.rb', line 37

def workflow_info(workflow_id)
  run = Persistence.workflow_runs.find_by_workflow_id(workflow_id)
  Workflow::Info.from(run)
end