[P] Fix wrong row sending order

2026-03-25 22:57:52 +02:00
1 changed files with 1 additions and 1 deletions
@@ -96,7 +96,7 @@ async def create_processed_agent_data(data: List[ProcessedAgentData], user_id: i
        created_records = [dict(row._mapping) for row in result.fetchall()]
        session.commit()

-        for record in created_records:
+        for record in sorted(created_records, key = lambda x: x['timestamp']):
            await send_data_to_subscribers(jsonable_encoder(record))
        return created_records
    except Exception as err: