2017-06-22 3 views
0

Je ne comprends pas quelle (s) commande (s) je dois exécuter pour obtenir un DAG planifié. Disons que j'ai testé le DAG en utilisant airflow test dag_name task_id_1 2017-06-22 et la deuxième tâche avec airflow test dag_name task_id_2 2017-06-22.Quelle est la séquence appropriée de commandes Airflow à exécuter pour planifier un DAG?

J'ai couru airflow trigger_dag dag_name, mais est-ce pour instancier le DAG pour juste ce moment?

Disons que je veux le calendrier/planification de la dag_name à ressembler:

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

Je veux juste planifier et exécuter aujourd'hui et demain, à partir @ 18:00 UTC aujourd'hui et 24 heures après cette.

Maintenant, quelle commande ou liste de commandes dois-je exécuter? Dois-je exécuter airflow scheduler chaque fois que je souhaite ajouter et planifier un groupe de disponibilité de base de données? Trigger_dag est de déclencher l'exécution de dag instantanément.

Répondre

0

Pour planifier le DAG, placez-le simplement dans le dossier DAG, allez dans Airflow UI et activez le DAG.