diff --git a/store/main.py b/store/main.py
index e05a599..f1a1a4c 100644
--- a/store/main.py
+++ b/store/main.py
@@ -49,7 +49,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: int):
         # send already available data
         r = processed_agent_data.select().order_by(processed_agent_data.c.timestamp)
         session = SessionLocal()
-        stored_data = SessionLocal().execute(r).fetchall()
+        stored_data = session.execute(r).fetchall()
         session.close() 
 
         jsonable_data = [{c.name: getattr(i, c.name) for c in processed_agent_data.columns} for i in stored_data]