Warren Marriott
10/13/2020, 10:37 PMsandy
10/14/2020, 1:06 AMWarren Marriott
10/14/2020, 1:40 PMsandy
10/14/2020, 3:36 PM@schedule(pipeline_name=pipeline_name, cron_schedule=...)
def my_daily_schedule(context):
return <config that parameterizes the pipeline to operate over all partitions>
Warren Marriott
10/14/2020, 3:41 PM