Refresh backup result per cycle
diff --git a/staffeln/conductor/backup.py b/staffeln/conductor/backup.py
index 5a489b3..6f251bd 100755
--- a/staffeln/conductor/backup.py
+++ b/staffeln/conductor/backup.py
@@ -41,6 +41,9 @@
def publish_backup_result(self):
self.result.publish()
+ def refresh_backup_result(self):
+ self.result.initialize()
+
def get_backups(self, filters=None):
return objects.Volume.list(self.ctx, filters=filters)
diff --git a/staffeln/conductor/manager.py b/staffeln/conductor/manager.py
index e77ef8e..456e37e 100755
--- a/staffeln/conductor/manager.py
+++ b/staffeln/conductor/manager.py
@@ -103,6 +103,7 @@
# Refresh the task queue
def _update_task_queue(self):
LOG.info(_("Updating backup task queue..."))
+ self.controller.refresh_backup_result()
current_tasks = self.controller.get_queues()
self.controller.create_queue(current_tasks)
diff --git a/staffeln/conductor/result.py b/staffeln/conductor/result.py
index 8f51588..b16bcc6 100644
--- a/staffeln/conductor/result.py
+++ b/staffeln/conductor/result.py
@@ -18,6 +18,9 @@
class BackupResult(object):
def __init__(self):
+ pass
+
+ def initialize(self):
self.content = ""
self.project_list = []
self.success_backup_list = {}