Revert "Clean global variable"

FlavorFlav · Jan 18, 2022 · eca734a · eca734a
1 parent 1565a9a
commit eca734a
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/ckan/lib/redis.py b/ckan/lib/redis.py
@@ -16,6 +16,10 @@
 
 log = logging.getLogger(__name__)
 
+# Redis connection pool. Do not use this directly, use ``connect_to_redis``
+# instead.
+_connection_pool = None
+
 
 def connect_to_redis():
     u'''
@@ -29,9 +33,11 @@ def connect_to_redis():
 
     .. seealso:: :py:func:`is_redis_available`
     '''
-    url = config.get_value('ckan.redis.url')
-    log.debug(u'Using Redis at {}'.format(url))
-    _connection_pool = ConnectionPool.from_url(url)
+    global _connection_pool
+    if _connection_pool is None:
+        url = config.get_value('ckan.redis.url')
+        log.debug(u'Using Redis at {}'.format(url))
+        _connection_pool = ConnectionPool.from_url(url)
     return Redis(connection_pool=_connection_pool)