From 65432beca8aa33d5ed426c4853d7aa66909c778a Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Mon, 8 Nov 2021 08:23:55 +0100 Subject: [PATCH] Added database nodes cleanup on errors. Signed-off-by: Cristiano Urban --- transfer_service/import_executor.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/transfer_service/import_executor.py b/transfer_service/import_executor.py index 99fac24..0e25558 100644 --- a/transfer_service/import_executor.py +++ b/transfer_service/import_executor.py @@ -234,6 +234,9 @@ class ImportExecutor(TaskExecutor): self.jobObj.setEndTime(datetime.datetime.now().isoformat()) self.dbConn.insertJob(self.jobObj) self.logger.info("Job phase updated to ERROR.") + self.logger.info("Removing VOSpace nodes from the database...") + self.dbConn.deleteNodesByJobId(self.jobId) + self.logger.info("Database cleanup completed") msg = f""" ########## VOSpace import procedure summary ########## -- GitLab