Ne pas lancer le DAG create_display_actor en parallèle et résoudre une dépendance

kolok · kolok · commit 2553c9026722 · 2025-02-12T12:01:37.000+01:00
diff --git a/dags/compute_acteurs/dags/create_final_actors.py b/dags/compute_acteurs/dags/create_final_actors.py
@@ -40,6 +40,7 @@
         " services."
     ),
     schedule=None,
+    max_active_runs=1,
 )
 
 load_acteur_task = PythonOperator(
@@ -152,6 +153,7 @@
     load_revisionpropositionservice_task,
     load_propositionservice_sous_categories_task,
     load_revisionpropositionservice_sous_categories_task,
+    load_revisionacteur_task,
 ] >> compute_ps_task_instance
 [
     load_revisionacteur_task,

Original file line number	Diff line number	Diff line change
`@@ -40,6 +40,7 @@`
`40`	`40`	`" services."`
`41`	`41`	`),`
`42`	`42`	`schedule=None,`
	`43`	`+ max_active_runs=1,`
`43`	`44`	`)`
`44`	`45`
`45`	`46`	`load_acteur_task = PythonOperator(`
`@@ -152,6 +153,7 @@`
`152`	`153`	`load_revisionpropositionservice_task,`
`153`	`154`	`load_propositionservice_sous_categories_task,`
`154`	`155`	`load_revisionpropositionservice_sous_categories_task,`
	`156`	`+ load_revisionacteur_task,`
`155`	`157`	`] >> compute_ps_task_instance`
`156`	`158`	`[`
`157`	`159`	`load_revisionacteur_task,`