Anh Nguyen
01/13/2022, 12:59 AMKevin Kho
Anh Nguyen
01/13/2022, 5:33 AMKevin Kho
StartFlowRun
task with wait=True
and add a scheduled_start_time
Anh Nguyen
01/13/2022, 6:16 AMKevin Kho
start = StartFlowRun(flow_name=.., project_name=..., wait=True)
@task
def get_time():
# four hours later
return datetime.datetime.now() + timedelta(hours=4)
with Flow(...) as flow:
time = get_time()
start(scheduled_start_time=time)