Browse Source

Fixes build

Ask Solem 9 years ago
parent
commit
96c16e0060
2 changed files with 3 additions and 2 deletions
  1. 1 1
      celery/backends/base.py
  2. 2 1
      celery/backends/redis.py

+ 1 - 1
celery/backends/base.py

@@ -444,7 +444,7 @@ class SyncBackendMixin(object):
             if timeout and time_elapsed >= timeout:
                 raise TimeoutError('The operation timed out.')
 
-    def add_pending_result(self, result):
+    def add_pending_result(self, result, weak=False):
         return result
 
     def remove_pending_result(self, result):

+ 2 - 1
celery/backends/redis.py

@@ -146,7 +146,8 @@ class RedisBackend(base.BaseKeyValueStoreBackend, async.AsyncBackendMixin):
             get_redis_error_classes() if get_redis_error_classes
             else ((), ()))
         self.result_consumer = self.ResultConsumer(
-            self, self.app, self.accept, self._pending_results)
+            self, self.app, self.accept,
+            self._pending_results, self._weak_pending_results)
 
     def _params_from_url(self, url, defaults):
         scheme, host, port, user, password, path, query = _parse_url(url)