Dagster v0.8.5 repository

repository.py

from dagster import repository, ScheduleDefinition

# This import fails in the scheduled run
from pipelines.test import test_pipeline


def define_pipelines():
    return [test_pipeline]


def define_schedules():
    return [
        ScheduleDefinition(
            name="test",
            cron_schedule="* * * * *",
            pipeline_name="test_pipeline"
        )
    ]


@repository
def define_repository():
    return define_pipelines() + define_schedules()