Merge pull request #225 from marketforce-tech/issue_223_extra_checks

feat: Do extra checks before releasing a lock
sibson · Sep 18, 2022 · 2e1e81e · 2e1e81e
2 parents 0768de0 + b05ca75
commit 2e1e81e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/redbeat/schedulers.py b/redbeat/schedulers.py
@@ -473,7 +473,8 @@ def tick(self, min=min, **kwargs):
     def close(self):
         if self.lock:
             logger.info('beat: Releasing lock')
-            self.lock.release()
+            if self.lock.owned() and self.lock.locked():
+                self.lock.release()
             self.lock = None
         super().close()