私は API ドキュメントを読んでいましたが、 BaseOperator.xcom_pullのcontext引数が何であるかが不明でした。
dag.default_argsになると思ったのですが、受け取りましたKeyError: 'ti'
こちらの push() の例に従って、前のタスク内で xcom_push を実行しました。
私は API ドキュメントを読んでいましたが、 BaseOperator.xcom_pullのcontext引数が何であるかが不明でした。
dag.default_argsになると思ったのですが、受け取りましたKeyError: 'ti'
こちらの push() の例に従って、前のタスク内で xcom_push を実行しました。