fix bug in work-queue implementation for 'Fine Parallel Processing Us…

…ing a Work Queue'
kubernetes · Sep 30, 2019 · 0b7af50 · 0b7af50
1 parent 2ec9665
commit 0b7af50
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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.