【问题标题】:Start Dagster Schedule automatically自动启动 Dagster 计划
【发布时间】: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


    【解决方案1】:

    Dagster GraphQL API 中有一个 startSchedule 突变,它有一个 Python 客户端。我不知道如何调用它来开始您的具体日程安排,但我认为这条路线是一个不错的选择。

    【讨论】:

      【解决方案2】:

      我对 dagster slack 有一个非常相同的问题,所以我转发 Daniel Gibson 的答案,这可能会有所帮助。

      • 从 0.14.0 版本开始,可以创建已经启用的时间表(将在一周内发布)。

      • 另外,还有一个dagster schedule start --start-all 命令行命令,调用它时添加计划将是一种解决方法

      【讨论】:

        猜你喜欢
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        • 2020-04-24
        • 2013-10-15
        • 1970-01-01
        • 2023-03-21
        • 1970-01-01
        • 2023-01-25
        相关资源
        最近更新 更多