Hi sorry but I can t figure out why my schedule is not getti dagster #ask-community

Hi, sorry but I can't figure out why my schedule i...

Jay Jackson

06/21/2022, 7:55 PM

Hi, sorry but I can't figure out why my schedule is not getting picked up by the

dagster-daemon

and I'm not seeing it in the dagit UI ..

dagster-daemon run -w dagster-workspace.yaml

Copy code

@schedule(
    cron_schedule="* * * * *",
    pipeline_name="my_job",
    job=my_job,
)
def my_job_schedule(context):
    # Find runs of the same job that are currently running
    run_records = context.instance.get_run_records(
        RunsFilter(job_name="my_job",
                   statuses=[DagsterRunStatus.STARTED]))

    # Kick off a run only if no other runs of the same job are running
    if len(run_records) == 0:
        yield RunRequest()

🤖 1

Jay Jackson

06/21/2022, 7:57 PM

I'm assuming the daemon has the schedule daemon inside of it so I don't need

dagster schedule start

, that cmd is giving me

There are no schedules defined for repository

also

rex

06/21/2022, 8:01 PM

your schedule should be contained in your

@repository

that you specified in your workspace.yaml. Could you show your repository definition?

Jay Jackson

06/21/2022, 8:02 PM

dagster-workspace.yaml

Copy code

load_from:
  - python_file:
      relative_path: data/workflow-recommendations.py

Jay Jackson

06/21/2022, 8:03 PM

workflow-recommendations.py

, I only have the @job decorator , do i need the @repository as well?

Jay Jackson

06/21/2022, 8:05 PM

like so -> https://docs.dagster.io/_apidocs/repositories#dagster.repository ?

Jay Jackson

06/21/2022, 8:10 PM

okay, i added @repository and i'm seeing the schedule in the UI now. didn't know i needed it.. I think i got it. Thanks for the response

rex

06/21/2022, 8:12 PM

Yup, here are the docs for this: https://docs.dagster.io/concepts/repositories-workspaces/repositories.

3 Views

Open in Slack

Previous Next