Johannes Müller
06/02/2023, 7:59 AMDefinitions
?
from dagster import Definitions, ScheduleDefinition
from airbyte.assets import run_middleware_db_redash_pipeline
Definitions(
jobs=[run_middleware_db_redash_pipeline],
schedules=[ScheduleDefinition(job=run_middleware_db_redash_pipeline, cron_schedule="0 * * * *")],
)
Johannes Müller
06/02/2023, 9:20 AMDefinitions
is completely ignored. If I comment it out I get the same result.Johannes Müller
06/02/2023, 9:24 AM@repository
def my_repo():
return [ScheduleDefinition(job=my_job, cron_schedule="0 * * * *")]
claire
06/02/2023, 5:01 PMDefinitions
object. Something like:
defs = Definitions(...)
Johannes Müller
06/02/2023, 5:23 PMJohannes Müller
06/02/2023, 5:27 PMJohannes Müller
06/02/2023, 5:28 PM