mypy

sanderegg · sanderegg · commit 4dd25a5efb79 · 2025-05-26T11:16:23.000+02:00
diff --git a/services/web/server/src/simcore_service_webserver/db_listener/_db_comp_tasks_listening_task.py b/services/web/server/src/simcore_service_webserver/db_listener/_db_comp_tasks_listening_task.py
@@ -67,7 +67,7 @@ async def _get_changed_comp_task_row(
     result = await conn.execute(
         select(comp_tasks).where(comp_tasks.c.task_id == task_id)
     )
-    return await result.fetchone()
+    return cast(RowProxy | None, await result.fetchone())
 
 
 async def _handle_db_notification(

Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,7 @@ async def _get_changed_comp_task_row(`
`67`	`67`	`result = await conn.execute(`
`68`	`68`	`select(comp_tasks).where(comp_tasks.c.task_id == task_id)`
`69`	`69`	`)`
`70`		`- return await result.fetchone()`
	`70`	`+ return cast(RowProxy \| None, await result.fetchone())`
`71`	`71`
`72`	`72`
`73`	`73`	`async def _handle_db_notification(`