【发布时间】:2021-10-29 18:41:55
【问题描述】:
您好,我正在学习 dagster,我需要有关开始时间表的帮助 我可以在 dagit 中添加和启动计划,但我想自动启动计划,而不是从 dagit 打开每个计划。
#这是我的代码
@solid()
def test(context):
context.log.info("test")
@pipeline()
def testPipeline():
test()
@schedule(
cron_schedule="* * * * *", pipeline_name="testPipeline", execution_timezone="Asia/Kolkata"
)
def scheduleTest():
return {}
@repository()
def testRepo():
return [testPipeline, scheduleTest]
【问题讨论】:
标签: python-3.x dagster