From 0b7af504de7fb9ada6f130d4333fb58747dea890 Mon Sep 17 00:00:00 2001 From: Daan Seynaeve Date: Mon, 30 Sep 2019 19:00:27 +0200 Subject: [PATCH] fix bug in work-queue implementation for 'Fine Parallel Processing Using a Work Queue' --- content/en/examples/application/job/redis/rediswq.py | 2 +- content/ja/examples/application/job/redis/rediswq.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/content/en/examples/application/job/redis/rediswq.py b/content/en/examples/application/job/redis/rediswq.py index ceda8bd1e32e0..2b8e81ceab79d 100644 --- a/content/en/examples/application/job/redis/rediswq.py +++ b/content/en/examples/application/job/redis/rediswq.py @@ -111,7 +111,7 @@ def complete(self, value): # If we crash here, then the GC code will try to move the value, but it will # not be here, which is fine. So this does not need to be a transaction. itemkey = self._itemkey(value) - self._db.delete(self._lease_key_prefix + itemkey, self._session) + self._db.delete(self._lease_key_prefix + itemkey) # TODO: add functions to clean up all keys associated with "name" when # processing is complete. diff --git a/content/ja/examples/application/job/redis/rediswq.py b/content/ja/examples/application/job/redis/rediswq.py index ceda8bd1e32e0..2b8e81ceab79d 100644 --- a/content/ja/examples/application/job/redis/rediswq.py +++ b/content/ja/examples/application/job/redis/rediswq.py @@ -111,7 +111,7 @@ def complete(self, value): # If we crash here, then the GC code will try to move the value, but it will # not be here, which is fine. So this does not need to be a transaction. itemkey = self._itemkey(value) - self._db.delete(self._lease_key_prefix + itemkey, self._session) + self._db.delete(self._lease_key_prefix + itemkey) # TODO: add functions to clean up all keys associated with "name" when # processing is complete.