Chu
@task('currency_orchestrator') def call_currency_orchestrator(): return create_flow_run( flow_name = "currency_orchestrator", project_name = "xxxx", )
aise TypeError("`fn` must be callable") TypeError: `fn` must be callable
Anna Geller
create_flow_run
create_flow_run.run()
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.