Skip to content

Instantly share code, notes, and snippets.

@santosnarom
Created June 29, 2020 09:02
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save santosnarom/7f42ba94d29fb8395f06ae2b12b8cb85 to your computer and use it in GitHub Desktop.
Dagster v0.8.5 repository
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()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment