python-3.x 自动启动Dagster计划

ajsxfq5m  于 2023-03-09  发布在  Python
关注(0)|答案(3)|浏览(130)

你好,我正在学习达Git,我想与启动时间表的帮助,我可以添加和启动时间表在达Git,但我想自动启动时间表,而不是打开每个时间表从达Git。
这是我的密码

@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]
ylamdve6

ylamdve61#

我有一个非常相同的问题,所以我转发丹尼尔吉布森的答案可能会有所帮助。

  • 从0.14.0版本开始,可以创建已启用计划(将在一周内发布)。
  • 此外,还有一个dagster schedule start --start-all命令行命令,调用该命令时,您可以随时添加日程表,这是一种解决方法
pgpifvop

pgpifvop2#

Dagster GraphQL API中有一个startSchedule变异,它有一个Python客户端,我不确定如何调用它来启动您的特定日程,但我认为这条路线是一个很好的选择。

a9wyjsp7

a9wyjsp73#

根据文档,您可以尝试以下操作:

my_running_schedule = ScheduleDefinition(
    job=my_job, cron_schedule="0 9 * * *", default_status=DefaultScheduleStatus.RUNNING
)

相关问题