2017-04-25 1 views

Répondre

0

Dags doit être rechargé lorsque vous mettez à jour le fichier python associé.

Si elles ne sont pas, essayez d'abord de les actualiser manuellement dans l'interface utilisateur en cliquant sur le bouton qui ressemble à un symbole de recyclage:

airflow ui refresh button

Si cela ne fonctionne pas, supprimer tous les fichiers .pyc dans le dossier dags.

Habituellement, quand je sauvegarde le fichier python, le dag est mis à jour en quelques instants.

0

Dans votre airflow.cfg, vous avez ces deux configurations pour contrôler ce comportement:

# after how much time a new DAGs should be picked up from the filesystem 
min_file_process_interval = 0 
dag_dir_list_interval = 60 

Vous pourriez avoir à recharger le serveur web, planificateur et travailleurs pour votre nouvelle configuration prenne effet.