diff --git a/api/core/app/apps/common/workflow_response_converter.py b/api/core/app/apps/common/workflow_response_converter.py
index 68eb95fab36..e95a68c0b44 100644
--- a/api/core/app/apps/common/workflow_response_converter.py
+++ b/api/core/app/apps/common/workflow_response_converter.py
@@ -856,7 +856,9 @@ class WorkflowResponseConverter:
         return tuple(flattened_files)
 
     @classmethod
-    def _fetch_files_from_variable_value(cls, value: Union[dict, list, Segment]) -> Sequence[Mapping[str, Any]]:
+    def _fetch_files_from_variable_value(
+        cls, value: Union[dict, list, Segment, File, None]
+    ) -> Sequence[Mapping[str, Any]]:
         """
         Fetch files from variable value
         :param value: variable value
@@ -871,7 +873,6 @@ class WorkflowResponseConverter:
                 files.append(value.value.to_dict())
             case ArrayFileSegment():
                 files.extend([i.to_dict() for i in value.value])
-            # pyrefly: ignore [unreachable-match-case]
             case File():
                 files.append(value.to_dict())
             case list():
diff --git a/api/core/app/task_pipeline/easy_ui_based_generate_task_pipeline.py b/api/core/app/task_pipeline/easy_ui_based_generate_task_pipeline.py
index 32ec381d798..3c519b3e108 100644
--- a/api/core/app/task_pipeline/easy_ui_based_generate_task_pipeline.py
+++ b/api/core/app/task_pipeline/easy_ui_based_generate_task_pipeline.py
@@ -373,12 +373,11 @@ class EasyUIBasedGenerateTaskPipeline(BasedGenerateTaskPipeline[EasyUIAppGenerat
 
         delta_text = ""
         # EasyUI streams text only; structured multimodal chunks contribute their text parts.
-        for content in delta_content:
+        for content in cast(list[object], delta_content):
             logger.debug("The content type %s in LLM chunk delta message content.: %r", type(content), content)
             match content:
                 case TextPromptMessageContent():
                     delta_text += content.data
-                # pyrefly: ignore [unreachable-match-case]
                 case str():
                     delta_text += content
                 case _:
diff --git a/api/core/mcp/session/base_session.py b/api/core/mcp/session/base_session.py
index f785ae6509f..26c1fc1700a 100644
--- a/api/core/mcp/session/base_session.py
+++ b/api/core/mcp/session/base_session.py
@@ -135,7 +135,7 @@ class BaseSession[
     messages when entered.
     """
 
-    _response_streams: dict[RequestId, queue.Queue[JSONRPCResponse | JSONRPCError | HTTPStatusError]]
+    _response_streams: dict[RequestId, queue.Queue[JSONRPCResponse | JSONRPCError | HTTPStatusError | None]]
     _request_id: int
     _in_flight: dict[RequestId, RequestResponder[ReceiveRequestT, SendResultT]]
     _receive_request_type: type[ReceiveRequestT]
@@ -216,7 +216,7 @@ class BaseSession[
         request_id = self._request_id
         self._request_id = request_id + 1
 
-        response_queue: queue.Queue[JSONRPCResponse | JSONRPCError | HTTPStatusError] = queue.Queue()
+        response_queue: queue.Queue[JSONRPCResponse | JSONRPCError | HTTPStatusError | None] = queue.Queue()
         self._response_streams[request_id] = response_queue
 
         try:
@@ -241,7 +241,6 @@ class BaseSession[
                     continue
 
             match response_or_error:
-                # pyrefly: ignore [unreachable-match-case]
                 case None:
                     raise MCPConnectionError(
                         ErrorData(