Skip to content
Snippets Groups Projects
Commit 65432bec authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added database nodes cleanup on errors.

parent aeaedd01
No related branches found
No related tags found
No related merge requests found
...@@ -234,6 +234,9 @@ class ImportExecutor(TaskExecutor): ...@@ -234,6 +234,9 @@ class ImportExecutor(TaskExecutor):
self.jobObj.setEndTime(datetime.datetime.now().isoformat()) self.jobObj.setEndTime(datetime.datetime.now().isoformat())
self.dbConn.insertJob(self.jobObj) self.dbConn.insertJob(self.jobObj)
self.logger.info("Job phase updated to ERROR.") 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""" msg = f"""
########## VOSpace import procedure summary ########## ########## VOSpace import procedure summary ##########
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment