Start Dagster Schedule automatically

Question

Hi i am learning dagster and i want help with starting schedule I am able to add and start schedule in dagit but i want to start schedule automatically instead of turn on every schedule from dagit.

#Here is my code

@solid()
def test(context):
   context.log.info("test")
  
@pipeline()
def testPipeline():
    test()

@schedule(
    cron_schedule="* * * * *", pipeline_name="testPipeline", execution_timezone="Asia/Kolkata"
)
def scheduleTest():
    return {}

@repository()
def testRepo():
    return [testPipeline, scheduleTest]

score 3 · Answer 1 · answered Feb 08 '22 at 20:18

I had a very same question on dagster slack so I'm forwarding Daniel Gibson's answer which might help.

since 0.14.0 release, it will be possible to create already enabled schedule (will be released in a week).
also, there's a dagster schedule start --start-all command line command, calling that any time you add a schedule would be one workaround

score 2 · Answer 2 · answered Sep 07 '21 at 16:56

2

There's a startSchedule mutation in the Dagster GraphQL API, which has a Python client. I'm not sure how to call it to start your specific schedule, but I think this route is a good way to go.

answered Sep 07 '21 at 16:56

Donny Winston

2,324
1
15
13

score 1 · Answer 3 · answered Mar 06 '23 at 11:43

1

According to the docs you can try this:

my_running_schedule = ScheduleDefinition(
    job=my_job, cron_schedule="0 9 * * *", default_status=DefaultScheduleStatus.RUNNING
)

answered Mar 06 '23 at 11:43

doublethink13

633
8
19

Start Dagster Schedule automatically

3 Answers3