From 060c7f2b45e6fb8feda664b6903534865cee6779 Mon Sep 17 00:00:00 2001 From: hjlarry Date: Mon, 19 Jan 2026 21:47:46 +0800 Subject: [PATCH] fix pyright --- api/controllers/console/__init__.py | 2 +- api/repositories/workflow_collaboration_repository.py | 7 ++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/api/controllers/console/__init__.py b/api/controllers/console/__init__.py index fad1af707f..2eb9d55e48 100644 --- a/api/controllers/console/__init__.py +++ b/api/controllers/console/__init__.py @@ -113,7 +113,7 @@ from .explore import ( recommended_app, saved_message, ) -from .socketio import workflow as socketio_workflow +from .socketio import workflow as socketio_workflow # pyright: ignore[reportUnusedImport] # Import tag controllers from .tag import tags diff --git a/api/repositories/workflow_collaboration_repository.py b/api/repositories/workflow_collaboration_repository.py index 2c06e90755..ad8a0a7807 100644 --- a/api/repositories/workflow_collaboration_repository.py +++ b/api/repositories/workflow_collaboration_repository.py @@ -93,7 +93,12 @@ class WorkflowCollaborationRepository: def get_session_sids(self, workflow_id: str) -> list[str]: raw_sids = self._redis.hkeys(self.workflow_key(workflow_id)) - return [self._decode(sid) for sid in raw_sids if self._decode(sid)] + decoded_sids: list[str] = [] + for sid in raw_sids: + decoded = self._decode(sid) + if decoded: + decoded_sids.append(decoded) + return decoded_sids def list_sessions(self, workflow_id: str) -> list[WorkflowSessionInfo]: sessions_json = self._redis.hgetall(self.workflow_key(workflow_id))