Database: Fix threading error

1 files changed, 2 insertions, 2 deletions

diff --git a/database.py b/database.py
index c59c5b8..2559b0f 100644
--- a/database.py
+++ b/database.py
@@ -4,7 +4,7 @@ from bson.objectid import ObjectId
 from datetime import datetime
 import sqlalchemy as db
 from sqlalchemy.ext.declarative import declarative_base
-from sqlalchemy.orm import relationship, sessionmaker
+from sqlalchemy.orm import relationship, sessionmaker, scoped_session
 
 BLOCKSIZE = 1024 ** 2
 
@@ -154,4 +154,4 @@ class Vote(Base):
 engine = db.create_engine("sqlite:///parry.db")
 Base.metadata.bind = engine
 Base.metadata.create_all(engine)
-DBSession = sessionmaker(bind=engine)
+DBSession = scoped_session(sessionmaker(bind=engine))