BUGFIX: RethinkDB backend connection

Updating the RethinkDB backend to check if a connection exists before creating one.
APSL · May 20, 2018 · 8d9bdfd · 8d9bdfd
1 parent c5b440a
commit 8d9bdfd
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/kaneda/backends/rethink.py b/kaneda/backends/rethink.py
@@ -39,6 +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
+        if self.connection is None:
+            self.connection = r.connect(db=db, timeout=timeout)
         self._create_database()
 
     def _get_payload(self, name, value, tags, id_):