2017-09-28 6 views
1

こんにちは、私は私のDAGパラメータはとてもエアフロー:ファイル名を指定して実行DAG分ごと

default_args = { 'owner': 'airflow', 'depends_on_past': False, 'start_date': datetime(2017, 9, 26), 'schedule_interval': "* * * * *", 'email': ['[email protected]'], 'email_on_failure': False, 'email_on_retry': False, }

として構成している。しかし、私は分離れたりどこかで、これらすべてのタスクをスケジュール私のエアフロースケジューラが表示されません。私もこのquestionと相談しましたが、うまく動作していないようです。 DAGを構築するときに何か不足していますか?

+0

DAGは有効になっていますか? UIのメインページに行くと、各DAGによってオン/オフ切り替えが行われるはずです。 –

+1

スケジューラは稼働していますか? https://airflow.incubator.apache.org/faq.html#why-isn-t-my-task-getting-scheduledの文書を参照しましたか? –

+0

はい、スケジューラが実行されており、DAGが有効です。私は奇妙な間隔を取得している、私は期待どおり毎分の更新ではない –

答えて

2

私はこの約100%わからないんだけど(とだけ試してみて、確認するために、気流コードに掘り始めた)しかし、あなたはそうのようなDAGにスケジュール間隔を渡す必要があります

dag = DAG(DAG_NAME, schedule_interval='* * * * *', default_args=default_args) 

私はあなたがしたようにそれをしようとしていたし、運もなかった。私のスケジュール間隔は0 12 * * *ですが、これは私のために働くように思えました。

+1

ああそれはすべきである。これまではhttps://stackoverflow.com/a/46183148/1969152で説明しましたが、それでも見逃してしまいました。 –

関連する問題