Explorar o código

archive checkpoint: Reset timer after the checkpoint has been committed

Jonas Borgström %!s(int64=11) %!d(string=hai) anos
pai
achega
9dce2362cc
Modificáronse 1 ficheiros con 2 adicións e 3 borrados
  1. 2 3
      attic/archive.py

+ 2 - 3
attic/archive.py

@@ -163,10 +163,9 @@ class Archive:
 
     def add_item(self, item):
         self.items_buffer.add(item)
-        now = time.time()
-        if now - self.last_checkpoint > self.checkpoint_interval:
-            self.last_checkpoint = now
+        if time.time() - self.last_checkpoint > self.checkpoint_interval:
             self.write_checkpoint()
+            self.last_checkpoint = time.time()
 
     def write_checkpoint(self):
         self.save(self.checkpoint_name)