diff --git a/store/main.py b/store/main.py index 7426fd6..38a1ae6 100644 --- a/store/main.py +++ b/store/main.py @@ -47,7 +47,10 @@ async def websocket_endpoint(websocket: WebSocket): try: # send already available data - r = processed_agent_data.select().order_by(processed_agent_data.c.timestamp) + r = processed_agent_data.select() \ + .where(processed_agent_data.c.visible == True) \ + .order_by(processed_agent_data.c.timestamp) + session = SessionLocal() stored_data = session.execute(r).fetchall() session.close()