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))