https://dagster.io/ logo
#ask-community
Title
# ask-community
s

Sanidhya Singh

04/25/2022, 6:47 AM
I have schedule which should run every 90 mins but instead runs every 60 mins. Any ideas? Dagster 0.14.1 schedule definition
Copy code
@schedule(
    cron_schedule="*/90 * * * *",
    job=pipeline_name,
    execution_timezone='Asia/Kolkata',
)
def schedule_name(date):
    return {}
d

daniel

04/25/2022, 1:28 PM
Hi Sanidhya, I don't think that's actually a valid cron string. I'm a little surprised that we are interpreting it as every 60 minutes, but what I would do is this:
Copy code
@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({})
s

Sanidhya Singh

04/25/2022, 1:36 PM
Ah, I see. Thanks Daniel!
Is there support for
fcron
?
d

daniel

04/25/2022, 1:47 PM
we have support for standard cron-string and vixie-style cron strings. Is there a particular fcron-specific syntax you want to use?
4 Views