2017-06-22 4 views
0

DAGをスケジュールするために実行する必要のあるコマンドがわかりません。 airflow test dag_name task_id_1 2017-06-22を使用してDAGをテストし、2番目のタスクをairflow test dag_name task_id_2 2017-06-22とテストしたとしましょう。DAGをスケジュールするために実行するエアフローコマンドの正しい順序は何ですか?

私はairflow trigger_dag dag_nameを実行しましたが、その時点でDAGをインスタンス化するためのものですか?

のは、私が見えるようにdag_nameのタイミング/スケジューリングしたいとしましょう:だから私はちょうど今日午前18時00 UTC @開始、今日と明日のスケジュールを設定し、それを実行すると、24時間後に

'start_date': datetime.datetime(2017, 6, 22, 18), 
'end_date': datetime.datetime(2017, 6, 23, 20), 
schedule_interval = datetime.timedelta(1) 

をそれ。

今実行するコマンドまたはコマンドのリストはありますか? DAGを追加してスケジュールするたびにairflow schedulerを実行する必要がありますか?

答えて

0

trigger_dagは、即時にダグランをトリガすることです。 DAGをスケジュールするには、DAGフォルダに配置し、Airflow UIに移動してDAGを有効にします。

関連する問題