Or, you can use the @dag decorator to turn a function into a DAG generator: ... @task.branch(task_id="branch_task") def branch_func(ti=None): xcom_value ...
確定! 回上一頁