diff --git a/transfer_service/import_executor.py b/transfer_service/import_executor.py
index 99fac244a1b5e4702f5e1ef797bee3e0b2c54001..0e25558f78af4f305864adecb4415fc33285856e 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 ##########