Add a `threading.Lock()` around `cursor.execute(...)` in Database.py

1 files changed, 3 insertions, 2 deletions

diff --git a/src/Database.py b/src/Database.py
index 1ed977de..28d86960 100644
--- a/src/Database.py
+++ b/src/Database.py
@@ -274,6 +274,7 @@ class Database(object):
             check_same_thread=False, isolation_level=None)
         self.database.execute("PRAGMA foreign_keys = ON")
         self._cursor = None
+        self._lock = threading.Lock()
 
         self.make_servers_table()
         self.make_channels_table()
@@ -307,8 +308,8 @@ class Database(object):
         start = time.monotonic()
 
         cursor = self.cursor()
-        cursor.execute(query, params)
-        value = fetch_func(cursor)
+        with self._lock:
+            cursor.execute(query, params)
 
         end = time.monotonic()
         total_milliseconds = (end - start) * 1000