commit aaeb047e40d88debfc789c938a45bbf3acf2611c
author okozachenko1203 <okozachenko1203@gmail.com> Tue May 17 02:28:15 2022 +1000
committer okozachenko1203 <okozachenko1203@gmail.com> Tue May 17 02:32:58 2022 +1000
tree ddc01e0cfd664fe7496112e16ce2bd5d9e0695a2
parent 34da944dbe34ddc8ba20a3aa8848494b1e198490

Add exception for failures to delete pre-failed backups

staffeln/conductor/backup.py

diff --git a/staffeln/conductor/backup.py b/staffeln/conductor/backup.py
index 9d3ee0e..70db2b5 100755
--- a/staffeln/conductor/backup.py
+++ b/staffeln/conductor/backup.py
@@ -209,7 +209,10 @@
 
         except OpenstackSDKException as e:
             LOG.info(
-                _("Backup %s deletion failed." "%s" % (backup_object.backup_id, str(e)))
+                _(
+                    "Backup %s deletion failed. Need to delete manually."
+                    "%s" % (backup_object.backup_id, str(e))
+                )
             )
 
             # TODO(Alex): Add it into the notification queue
@@ -340,7 +343,7 @@
             "The backup creation for the volume %s was prefailed." % task.volume_id
         )
         self.result.add_failed_backup(task.project_id, task.volume_id, reason)
-        # LOG.error(reason)
+        LOG.warn(reason)
         # 2. remove failed task from the task queue
         task.delete_queue()
 
@@ -348,9 +351,17 @@
         # 1. notify via email
         reason = _("The status of backup for the volume %s is error." % task.volume_id)
         self.result.add_failed_backup(task.project_id, task.volume_id, reason)
-        LOG.error(reason)
+        LOG.warn(reason)
         # 2. delete backup generator
-        self.openstacksdk.delete_backup(uuid=task.backup_id, force=True)
+        try:
+            self.openstacksdk.delete_backup(uuid=task.backup_id, force=True)
+        except OpenstackHttpException as ex:
+            LOG.error(
+                _(
+                    "Failed to delete volume backup %s. %s. Need to delete manually."
+                    % (task.backup_id, str(ex))
+                )
+            )
         # 3. remove failed task from the task queue
         task.delete_queue()
 
@@ -392,6 +403,7 @@
             return
         if project_id not in self.project_list:
             self.process_non_existing_backup(queue)
+            return
         self.openstacksdk.set_project(self.project_list[project_id])
         backup_gen = self.openstacksdk.get_backup(queue.backup_id)