diff --git a/mongoqueue/mongoqueue.py b/mongoqueue/mongoqueue.py index bce2aa8..cefaafe 100644 --- a/mongoqueue/mongoqueue.py +++ b/mongoqueue/mongoqueue.py @@ -66,7 +66,7 @@ def repair(self): query={ "locked_by": {"$ne": None}, "locked_at": { - "$lt": datetime.now() - timedelta(self.timeout)}}, + "$lt": datetime.now() - timedelta(seconds=self.timeout)}}, update={ "$set": {"locked_by": None, "locked_at": None}, "$inc": {"attempts": 1}}