Add more logging to workers

AutomatedProcessImprovement · Jan 31, 2024 · 777cc0a · 777cc0a
1 parent b079e5b
commit 777cc0a
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git a/backend/workers/bps-discovery-simod/bps_discovery_simod/simod.py b/backend/workers/bps-discovery-simod/bps_discovery_simod/simod.py
@@ -142,9 +142,11 @@ async def process(self, processing_request: ProcessingRequest):
             # remove downloaded files
             for file in files_to_delete:
                 if file.path.exists():
+                    logger.info(f"Deleting file: {file.path}")
                     file.path.unlink()
             # remove results
             for dir in dirs_to_delete:
+                logger.info(f"Deleting directory: {dir}")
                 shutil.rmtree(dir, ignore_errors=True)
 
         # set token to None to force re-authentication, because the token might have expired

diff --git a/backend/workers/kronos/kronos/kronos_service.py b/backend/workers/kronos/kronos/kronos_service.py
@@ -171,8 +171,10 @@ async def process(self, processing_request: ProcessingRequest):
         finally:
             for file in files_to_delete:
                 if file.path.exists():
+                    logger.info(f"Deleting file: file_id={file.id}, path={file.path}")
                     file.path.unlink()
             for dir in dirs_to_delete:
+                logger.info(f"Deleting directory: path={dir}")
                 shutil.rmtree(dir, ignore_errors=True)
 
         # set token to None to force re-authentication, because the token might have expired

diff --git a/backend/workers/simulation-prosimos/simulation_prosimos/prosimos_service.py b/backend/workers/simulation-prosimos/simulation_prosimos/prosimos_service.py
@@ -186,6 +186,7 @@ async def process(self, processing_request: ProcessingRequest):
         finally:
             for file in files_to_delete:
                 if file.path.exists():
+                    logger.info(f"Deleting file: {file.path}")
                     file.path.unlink()
 
         # set token to None to force re-authentication, because the token might have expired