mirror of
https://github.com/langgenius/dify.git
synced 2026-08-30 17:11:50 +08:00
chore(api): remove unreachable match suppressions (#39949)
Co-authored-by: nightcityblade <nightcityblade@gmail.com>
This commit is contained in:
@@ -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():
|
||||
|
||||
@@ -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 _:
|
||||
|
||||
@@ -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(
|
||||
|
||||
Reference in New Issue
Block a user