Goh Rui Zhi
07/16/2021, 3:14 AMwith Flow("my_daily_flow", schedule) as flow:
start_date = Parameter("start_date", default=datetime.utcnow().date() - timedelta(days=5))
end_date = Parameter("start_date", default=datetime.utcnow().date())
daily_job.set_dependencies(keyword_tasks={"start_date": start_date, "end_date": end_date})
flow.register("test")
This question might have been asked before, but I would like some confirmation. Thank you!Kevin Kho
Parameter("x", default = "today")
, then pass that to a task that returns today.Kevin Kho
Goh Rui Zhi
07/16/2021, 3:03 PMMarko Jamedzija
07/26/2021, 10:14 AMMarko Jamedzija
07/26/2021, 11:59 AMrun_dt = Parameter(name="run_dt", default=(schedule.next(1)[0] - timedelta(days=1)).strftime("%Y-%m-%d"))
Marko Jamedzija
07/26/2021, 11:59 AMMarko Jamedzija
07/26/2021, 11:59 AM