Sanidhya Singh
04/25/2022, 6:47 AM@schedule(
cron_schedule="*/90 * * * *",
job=pipeline_name,
execution_timezone='Asia/Kolkata',
)
def schedule_name(date):
return {}
daniel
04/25/2022, 1:28 PM@schedule(
cron_schedule="*/30 * * * *",
job=pipeline_name,
execution_timezone='Asia/Kolkata',
)
def schedule_name(context):
scheduled_time = context.scheduled_execution_time
if (...) # add additional checks that it's happening on a 90 minute interval
yield RunRequest({})
Sanidhya Singh
04/25/2022, 1:36 PMSanidhya Singh
04/25/2022, 1:36 PMfcron
?daniel
04/25/2022, 1:47 PM