5

私は API ドキュメントを読んでいましたが、 BaseOperator.xcom_pullのcontext引数が何であるかが不明でした。

dag.default_argsになると思ったのですが、受け取りましたKeyError: 'ti'

こちらの push() の例に従って、前のタスク内で xcom_push を実行しました。

4

1 に答える 1