Fix multithreading in getData

Previously, the session was not automatically closing. This was causing sqlite to throw multithreading errors.
nqminds · Feb 6, 2019 · b5f3902 · b5f3902
1 parent 413db40
commit b5f3902
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/nqm/iotdatabase/database.py b/nqm/iotdatabase/database.py
@@ -435,6 +435,8 @@ def getData(self,
             {x: a for x, a in row.__dict__.items() if x not in noproject}
             for row in mongoquery.all()
         ]
+        # close the ORM session when done
+        session.close()
 
         data = [schemaconverter.convertRowToTdx(
             schema, row, data_dir) for row in projected_data]