feat: delete local flux file once sent to MinIO

annuaire-entreprises-data-gouv-fr · Nov 17, 2023 · bc715b4 · bc715b4
1 parent 74c58eb
commit bc715b4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/data_pipelines/rne/flux/flux_tasks.py b/data_pipelines/rne/flux/flux_tasks.py
@@ -178,6 +178,8 @@ def get_and_save_daily_flux_rne(
             ],
         )
         logging.info(f"****** Sent file to MinIO: {json_file_name}")
+        logging.info(f"****** Deleting file: {json_file_path}")
+        os.remove(json_file_path)
 
 
 def get_every_day_flux(ti):