From 1a68c1005e7d63b4213d3e95ed01536c641085a7 Mon Sep 17 00:00:00 2001 From: Karthik T Date: Mon, 26 Oct 2015 11:56:29 +0800 Subject: [PATCH] Fix timeout repair feature to do "timeout" seconds instead of days Please refer to comment on https://github.com/kapilt/mongoqueue/issues/4 --- mongoqueue/mongoqueue.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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}}