We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 40bf79b commit 1a68c10Copy full SHA for 1a68c10
1 file changed
mongoqueue/mongoqueue.py
@@ -66,7 +66,7 @@ def repair(self):
66
query={
67
"locked_by": {"$ne": None},
68
"locked_at": {
69
- "$lt": datetime.now() - timedelta(self.timeout)}},
+ "$lt": datetime.now() - timedelta(seconds=self.timeout)}},
70
update={
71
"$set": {"locked_by": None, "locked_at": None},
72
"$inc": {"attempts": 1}}
0 commit comments