diff --git a/src/opserver/partition_handler.py b/src/opserver/partition_handler.py
index e9f462337af..5a6a7607621 100644
--- a/src/opserver/partition_handler.py
+++ b/src/opserver/partition_handler.py
@@ -417,6 +417,8 @@ 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)
@@ -424,6 +426,7 @@ def _run(self):
                                   (self._pi.ip_address, self._pi.port, \
                                    self._pi.instance_id, self._partno, \
                                    messag, traceback.format_exc()))
+            finally:
                 lredis = None
                 if pb is not None:
                     pb.close()