Hey guys, I've got an issue running my scheduled j...
# troubleshooting
i
Hey guys, I've got an issue running my scheduled jobs in dagster. I've got the CRON schedule defined for my asset group, have all the correct pipelines defined in the job, and have successfully materialized a full run of my assets with the "Materialize all" button in the dagster UI. However, my instance doesn't seem to be running the jobs on the schedule. I had this set up to run nightly and that was failing so I just built a dev container locally and switched my cron schedule to run at 9:30am and it failed (did not run the job). Here's what my schedule def looks like:
Copy code
basic_schedule = ScheduleDefinition(
            job=asset_job,
            cron_schedule=spec.cron_schedule,
            default_status=DefaultScheduleStatus.RUNNING
        )
Here's what the schedule looks like in the tap:
Copy code
ALL_TAP_STREAMS: List[MeltanoSpec] = [
    MeltanoSpec(
        'tap', 
        [
            "stream_1",
            "stream_2",
            etc...
        ],
        "30 9 * * *",
    ),
c
zero experience with Dagster but in Airflow I had a job which was disabled but still scheduled giving me fits - no logs, thought I was losing my mind - because I failed to notice it was disabled on deployment
a
How are you starting your dagster instance? Do you have a daemon active?
If you look under Deployment -> Daemons can you see a Scheduler daemon running?
i
datawarehouse-1  | 2024-08-12 15:18:08 +0000 - dagster.daemon - INFO - Instance is configured with the following daemons: ['AssetDaemon', 'BackfillDaemon', 'SchedulerDaemon', 'SensorDaemon']
The schedular also says running
along with backfill and sensors
I'm starting my dagster instance in my dockerfile bash entrypoint, essentially running
meltano invoke dagster:dev -f $REPOSITORY_DIR/repository.py --dagit-host 0.0.0.0 -d $REPOSITORY_DIR
Think I found the issue
image.png
Copy code
defs = Definitions(
    assets= (meltano_assets) + [dbt_project_assets],
    resources= resources,
    jobs= meltano_jobs,
    schedules= meltano_schedules
)
had the schedules commented out lmao
🤣 1
a
glad you found the fix
🤣 1