Fabrice Toussaint
04/23/2021, 11:45 AMZanie
04/23/2021, 1:41 PMFabrice Toussaint
04/23/2021, 2:51 PMZanie
04/23/2021, 3:05 PMFabrice Toussaint
04/28/2021, 8:11 AMZanie
04/28/2021, 1:58 PM- idempotency_key (str, optional): a unique idempotency key for scheduling the
flow run. Duplicate flow runs with the same idempotency key will only create
a single flow run. This is useful for ensuring that only one run is created
if this task is retried. If not provided, defaults to the active `task_run_id`.
Fabrice Toussaint
04/28/2021, 2:01 PMwith Flow as flow:
StartFlowRun().run(flow_name='flowname', project_name='projcctname',
parameters={})
StartFlowRun().run(flow_name='flowname', project_name='projcctname',
parameters={})
with this schedule
schedule = Schedule(clocks=[clocks.CronClock('0 */2 * * *')])
Zanie
04/28/2021, 2:03 PM.run()
directlystart_my_flow = StartFlowRun(flow_name='flowname', project_name='project')
with Flow(...) as flow:
start_my_flow(parameters={...})
Fabrice Toussaint
04/28/2021, 2:05 PM.run()
.run()
or should it automatically execute the flow with your example?Zanie
04/28/2021, 2:14 PMrun
method.run
method is executed at flow runtimeFabrice Toussaint
04/28/2021, 2:15 PMZanie
04/28/2021, 2:16 PM