flux d'air remblaiement dag run dépendance

Quand je remblayer un DAG pour des dates précises, je veux l'exécuter en séquence, à savoir que je veux qu'il soit exécuté jour par jourflux d'air remblaiement dag run dépendance

remplir toutes les tâches pour la journée spécifique et suivant Je ai utilisé l'argument depends_on_past, mais cela ne m'aide qu'à définir la dépendance sur les tâches qui ne sont pas dans dag runs.

exemple: - Dag_A ont 4 tâches, j'utilise remblayage avec depends_on_past, Après l'exécution de la première tâche Dag_A (premier jour), il déclenche la première tâche de Dag_A (deuxième jour), je ne veux pas qu'il

Source

2017-06-29 Francy R7

Bienvenue dans StackOverflow. S'il vous plaît montrer vos propres tentatives de codage. Peut-être sous la forme d'un [mcve], de nombreux utilisateurs sont très désireux de voir cela. Vous pourriez aussi vouloir faire le [tour]. – Yunnosch

Peut-être dans le dag max_active_runs = 1 –

J'ai essayé cela aussi, Il ne fonctionne pas dans le remblayage –

Il est une option permettant de définir le nombre maximum d'exécutions par dag dans le fichier global airflow.cfg. Le paramètre à définir est max_active_runs_per_dag.

Source

2017-07-03 13:24:18 Him

J'avais essayé la même chose .. mais il ne fonctionne pas dans le remblayage –

flux d'air remblaiement dag run dépendance

Répondre

Questions connexes