- BinaryDevelop

[解決済み] エアフローです。PythonOperator: なぜ 'ds' 引数をインクルードするのですか？

質問 Python_callable として使用される関数を定義しているとき、なぜ 'ds' が関数の最初の引数として含まれているのですか? 例えば def python_func(ds, **kwargs): pass Airflowのドキュメントを調べてみましたが、説明が見つかりませんでした。解決方法は？これは provide_context=True

2022-03-04 07:59:08
[解決済み] エアフロー on_failure_callback

質問こんにちは、皆様お元気でしょうか。最近、Airlfowを試して遊んでいるのですが、以下のような状況です。読み込み_csv 処理ファイル正常に動作するわざわざ pandas Datframeでtypoを作成し、失敗時のコールバックがどのように機能するかを学び、それがトリガーされているかどうかを確認するために、ログからdosentが好きなようです。 ''

2022-02-26 21:59:50

最新