Merge pull request #3 from neil-pozetroninc/master

BUGFIX: RethinkDB Backend
APSL · May 21, 2018 · f9e6426 · f9e6426
2 parents 745c37f + 8d9bdfd
commit f9e6426
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/kaneda/backends/rethink.py b/kaneda/backends/rethink.py
@@ -39,7 +39,8 @@ def __init__(self, db, table_name=None, connection=None, host=None, port=None, u
                 self.connection = r.connect(host=host, port=port, db=db, timeout=timeout)
         self.db = db
         self.table_name = table_name
-        self.connection = r.connect(db=db, timeout=timeout)
+        if self.connection is None:
+            self.connection = r.connect(db=db, timeout=timeout)
         self._create_database()
 
     def _get_payload(self, name, value, tags, id_):