call ping to set connection for avoiding error

when subscribed_to is empty , call ping to set connection attr for avoiding redis parse_response error
celery · Jan 12, 2022 · bc13e2f · bc13e2f
1 parent 9377e94
commit bc13e2f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/celery/backends/redis.py b/celery/backends/redis.py
@@ -112,6 +112,8 @@ def _reconnect_pubsub(self):
         )
         if self.subscribed_to:
             self._pubsub.subscribe(*self.subscribed_to)
+        else:
+            self._pubsub.ping()
 
     @contextmanager
     def reconnect_on_error(self):