小编AFZ*_*Z84的帖子

我曾经使用 python 运算符创建任务并在气流 1 中检索执行，如下所示

def task(**kwargs):
    date = kwargs['execution_date']

使用新的任务流 api 执行此操作的正确方法是什么？（可能错过了）

谢谢