Prateek Saigal
01/21/2022, 5:12 PMflow.schedule = CronSchedule("49 21 * * 1-5",start_date=pendulum.datetime(2022, 1, 1, tz="Asia/Kolkata"),)
flow.register(
project_name=project_name,
idempotency_key=flow.serialized_hash(),
labels=["test"],
)
What could be the reason for this?Kevin Kho
Prateek Saigal
01/21/2022, 5:14 PMKevin Kho
Prateek Saigal
01/21/2022, 5:15 PM# -- Write you flows here
with Flow(workflow_name) as flow:
today_date = datetime.datetime.now(pytz.timezone('Asia/Kolkata')).strftime("%Y%m%d")
date = Parameter("date", default=today_date
Kevin Kho
@task
def get_date(val):
if val == None:
return datetime.datetime.now(pytz.timezone('Asia/Kolkata')).strftime("%Y%m%d")
with Flow(...) as flow:
the_date = Parameter("today", default=None)
the_date = get_date(the_date)
Prateek Saigal
01/21/2022, 5:20 PMKevin Kho