任务1、2、3、4将插入到db表中。然后,我希望任务7只对带有时间戳>=的行更新db表,即dagrun的开始时间(而不是任务7的开始时间)。
我是否可以使用jinja/kwarg/ there宏?我没有看到任何获得dagrun start_date的例子(不是执行日期)。
发布于 2022-06-09 07:35:50
context变量包含许多包含任务上下文信息的变量,包括dag_run.start_date。
context['dag_run'].start_datehttps://stackoverflow.com/questions/64250582
复制相似问题