diff --git a/src/bluesky_blissdata/dispacher.py b/src/bluesky_blissdata/dispacher.py
index 9772b3865e01f194391a219e5114b4bb3a761bf5..5c6e3d8bdaddb9e2913dc66f68ff78ff879c75b8 100644
--- a/src/bluesky_blissdata/dispacher.py
+++ b/src/bluesky_blissdata/dispacher.py
@@ -25,10 +25,15 @@ class blissdata_dispacher:
     def __init__(self,host="localhost",port=6380) :
         _logger.info("Connecting to redis sever")
         try:
-            self._data_store = DataStore("redis://"+host+":"+str(port))
+            self._data_store = DataStore("redis://"+host+":"+str(port),init_db=True)
         except OSError as e:
             _logger.debug("Error in connecting to redis sever")
             raise ConnectionError(self._error_message(e))
+        except RuntimeError as e:
+            try: 
+                self._data_store = DataStore("redis://"+host+":"+str(port),init_db=True)
+            except RuntimeError as e:
+                raise RuntimeError(self._error_message(e))