fix: task id in xcom pull

annuaire-entreprises-data-gouv-fr · Nov 27, 2024 · bce989c · bce989c
1 parent f31045e
commit bce989c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/workflows/data_pipelines/egapro/egapro_processor.py b/workflows/data_pipelines/egapro/egapro_processor.py
@@ -34,6 +34,6 @@ def _push_unique_siren_count(self, df_egapro):
     def send_file_to_minio(self):
         super().send_file_to_minio()
         ti = get_current_context()["ti"]
-        nb_siren = ti.xcom_pull(key="nb_siren_egapro", task_ids="process_egapro")
+        nb_siren = ti.xcom_pull(key="nb_siren_egapro", task_ids="preprocess_egapro")
         message = f"{nb_siren} unités légales."
         ti.xcom_push(key=Notification.notification_xcom_key, value=message)