24

エアフローを使用して、コマンド ラインから手動でトリガーする特定のワークフローを定義しようとしています。

DAG を作成し、一連のタスクを追加します。

dag = airflow.DAG(
    "DAG_NAME",
    start_date=datetime(2015, 1, 1),
    schedule_interval=None,
    default_args=args)

次に、ターミナルで実行します

airflow trigger_dag DAG_NAME

そして何も起こりません。スケジューラは別のスレッドで実行されています。どんな方向でも大歓迎です。ありがとうございました

4

5 に答える 5

37

同じ問題が発生しました。

airflow list_dagsWeb サーバー内または Web サーバー経由でDAG を表示できると仮定すると、次のようになります。

Web UI で DAG をオンにするだけでなく、DAG がairflow scheduler別のプロセスとして実行されていることを確認する必要がありました。

スケジューラを実行すると、dag を使用して正常に実行できました。airflow trigger_dag <dag_id>

私の DAG 構成は、あなたのものと大きな違いはありません。私も持っていますschedule_interval=None

于 2016-09-13T21:34:15.207 に答える
10

ワークフローを無効にしている可能性があります。ワークフローを手動で有効にするには。気流ウェブサーバーを開きます

$ airflow webserver -p 8080

http://localhost:8080に移動します。使用可能なすべてのダグのリストが表示され、トグル ボタンのオン/オフが表示されます。デフォルトでは、すべてオフに設定されています。DAG を検索し、ワークフローを切り替えます。ここで、ターミナルからワークフローをトリガーしてみてください。今すぐ動作するはずです。

于 2016-06-29T11:01:47.620 に答える