問題タブ [apache-airflow]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
airflow - カスタム Airflow マクロで他のマクロを展開する
それ自体が他のマクロから計算される Airflow でユーザー定義マクロを作成する方法はありますか?
ここでの使用例は、新しい Airflow v1.8next_execution_dateマクロをバックポートして、Airflow v1.7 で動作するようにすることです。残念ながら、このテンプレートはマクロ展開なしでレンダリングされます。
airflow - 気流「one_success」タスクがトリガーされない
LocalExecutor を使用して 4 CPU マシンで Airflow を実行しています
アップストリーム タスクを 1 つの成功として定義しました
...
しかし、いくつかは明確に成功としてマークされていても、タスクはトリガーされません
「ダウンロードタスク」は並行して実行されるため、問題になることはありません
タスクを検査すると、次のことが示されます。
依存性: 不明
理由: すべての依存関係が満たされていますが、タスク インスタンスが実行されていません。ほとんどの場合、これは次の場合を除き、タスクがおそらくすぐにスケジュールされることを意味します: - スケジューラがダウンしているか、負荷が高い - このタスク インスタンスは既に実行されており、状態が手動で変更されている (例: UI でクリアされている)
私は負荷を見てきましたが、実際にはかなり高いです:
負荷平均: 2.45、3.55、3.71 CPU は 50 ～ 60% です
しかし、他のタスクはすでに終了しているので、別のタスクを開始するための空きリソースがあるはずですよね?