anti/DECNET
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: use model_dump(mode='json') to serialize datetime fields; fixes SSE stream silently dying post-ORM migration

Browse Source
This commit is contained in:
anti
2026-04-09 19:29:27 -04:00
parent cea6279a08
commit 14f7a535db
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
decnet/web/db/sqlite/repository.py
View File

@@ -166,7 +166,7 @@ class SQLiteRepository(BaseRepository):
async with self.session_factory() as session: async with self.session_factory() as session:
results = await session.execute(statement) results = await session.execute(statement)
return [log.model_dump() for log in results.scalars().all()] return [log.model_dump(mode='json') for log in results.scalars().all()]
async def get_max_log_id(self) -> int: async def get_max_log_id(self) -> int:
async with self.session_factory() as session: async with self.session_factory() as session:
@@ -189,7 +189,7 @@ class SQLiteRepository(BaseRepository):
async with self.session_factory() as session: async with self.session_factory() as session:
results = await session.execute(statement) results = await session.execute(statement)
return [log.model_dump() for log in results.scalars().all()] return [log.model_dump(mode='json') for log in results.scalars().all()]
async def get_total_logs( async def get_total_logs(
self, self,
@@ -338,7 +338,7 @@ class SQLiteRepository(BaseRepository):
results = await session.execute(statement) results = await session.execute(statement)
final = [] final = []
for item in results.scalars().all(): for item in results.scalars().all():
d = item.model_dump() d = item.model_dump(mode='json')
try: try:
d["payload"] = json.loads(d["payload"]) d["payload"] = json.loads(d["payload"])
except (json.JSONDecodeError, TypeError): except (json.JSONDecodeError, TypeError):