Просмотр исходного кода

Changed _apply_chord_incr to use int value

Wiliam Souza 10 лет назад
Родитель
Сommit
a4c17f8941
1 измененных файлов с 1 добавлено и 1 удалено
  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)
         return self.client.delete(key)
 
 
     def _apply_chord_incr(self, header, partial_args, group_id, body, **opts):
     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(
         return super(CacheBackend, self)._apply_chord_incr(
             header, partial_args, group_id, body, **opts
             header, partial_args, group_id, body, **opts
         )
         )