whentimeslows/website
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix bug in work-queue implementation for 'Fine Parallel Processing Using a Work Queue' (#16625)

Browse Source
This commit is contained in:
Daan Seynaeve
2019-10-07 03:59:08 +02:00
committed by Kubernetes Prow Robot
parent 232d99ef14
commit e6a6e422bd
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
content/en/examples/application/job/redis/rediswq.py
+1 -1
View File
@@ -111,7 +111,7 @@ class RedisWQ(object):
# 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.
content/ja/examples/application/job/redis/rediswq.py
+1 -1
View File
@@ -111,7 +111,7 @@ class RedisWQ(object):
# 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.