Explorar o código

Merge pull request #2575 from wiliamsouza/master

Changed _apply_chord_incr to use int value
PMickael %!s(int64=10) %!d(string=hai) anos
pai
achega
d7befd8638
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      celery/backends/cache.py

+ 1 - 1
celery/backends/cache.py

@@ -129,7 +129,7 @@ class CacheBackend(KeyValueStoreBackend):
         return self.client.delete(key)
 
     def _apply_chord_incr(self, header, partial_args, group_id, body, **opts):
-        self.client.set(self.get_key_for_chord(group_id), '0', time=86400)
+        self.client.set(self.get_key_for_chord(group_id), 0, time=86400)
         return super(CacheBackend, self)._apply_chord_incr(
             header, partial_args, group_id, body, **opts
         )