|
@@ -206,12 +206,9 @@ class RedisBackend(KeyValueStoreBackend):
|
|
|
.expire(jkey, 86400) \
|
|
|
.execute()
|
|
|
|
|
|
- print('YEA')
|
|
|
-
|
|
|
try:
|
|
|
callback = maybe_signature(request.chord, app=app)
|
|
|
total = callback['chord_size']
|
|
|
- print('TOTAL: %r' % (readycount, ))
|
|
|
if readycount >= total:
|
|
|
decode, unpack = self.decode, self._unpack_chord_result
|
|
|
resl, _ = client.pipeline() \
|