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.