commit 4d348c2f68243a7ea2f4116f59b21b7cfc555fed
author okozachenko <okozachenko@vexxhost.com> Wed May 05 13:04:25 2021 +0300
committer okozachenko <okozachenko@vexxhost.com> Wed May 05 13:04:25 2021 +0300
tree ffaee50df5d9743dde0bb181f384ea1fd76e191f
parent 0742b52eeeeedb79df4a55c58f7b1652be7e8e63

Change periodic schedule strategy from last_started to last_finished

staffeln/conductor/backup.py

diff --git a/staffeln/conductor/backup.py b/staffeln/conductor/backup.py
index 1b83409..69c48f4 100755
--- a/staffeln/conductor/backup.py
+++ b/staffeln/conductor/backup.py
@@ -132,7 +132,6 @@
                 queue.backup_status = constants.BACKUP_WIP

                 queue.save()

             except exceptions as error:

-                print("catch error")

                 print(error)

         else:

             pass

staffeln/conductor/manager.py

diff --git a/staffeln/conductor/manager.py b/staffeln/conductor/manager.py
index fc00d6b..78869e0 100755
--- a/staffeln/conductor/manager.py
+++ b/staffeln/conductor/manager.py
@@ -30,7 +30,7 @@
         periodic_callables = [
             (self.backup_engine, (), {}),
         ]
-        periodic_worker = periodics.PeriodicWorker(periodic_callables)
+        periodic_worker = periodics.PeriodicWorker(periodic_callables, schedule_strategy="last_finished")
         periodic_thread = threading.Thread(target=periodic_worker.start)
         periodic_thread.daemon = True
         periodic_thread.start()
@@ -98,7 +98,7 @@
         periodic_callables = [
             (self.rotation_engine, (), {}),
         ]
-        periodic_worker = periodics.PeriodicWorker(periodic_callables)
+        periodic_worker = periodics.PeriodicWorker(periodic_callables, schedule_strategy="last_finished")
         periodic_thread = threading.Thread(target=periodic_worker.start)
         periodic_thread.daemon = True
         periodic_thread.start()