Remplissage de l'air nouvelle tâche ajoutée à dag

Question

Disons que c'est aujourd'hui 2017-10-20. J'ai un dag existant qui réussit jusqu'à aujourd'hui. Je dois ajouter une tâche avec start_date du 2017-10-01. Comment faire automatiquement la tâche de déclenchement du planificateur de 2017-10-01 à 2017-10-20?

Answer 1

Vous pouvez utiliser l'outil de ligne de commande de renvoi.

airflow backfill your_dag_id -s 2017-10-01 -e 2017-10-20 -t task_name_regex 

Ceci suppose qu'il existe déjà un cycle DAG pour les dates commençant le 2017-10-01. Si ce n'est pas le cas, assurez-vous que la date de début du DAG est 2017-10-01 ou antérieure et que le rattrapage est activé.