diff --git a/src/opserver/partition_handler.py b/src/opserver/partition_handler.py
index b72ba8dc3e5..f9f1373a632 100644
--- a/src/opserver/partition_handler.py
+++ b/src/opserver/partition_handler.py
@@ -417,11 +417,14 @@ def _run(self):
 
             except gevent.GreenletExit:
                 break
+            except redis.exceptions.ConnectionError:
+                pass
             except Exception as ex:
                 template = "Exception {0} in uve stream proc. Arguments:\n{1!r}"
                 messag = template.format(type(ex).__name__, ex.args)
                 self._logger.error("%s : traceback %s" % \
                                   (messag, traceback.format_exc()))
+            finally:
                 lredis = None
                 if pb is not None:
                     pb.close()