|
|
|
|
|
|
|
|
|
|
|
|
|
|
text = "" |
|
|
text = "" |
|
|
files: list[File] = [] |
|
|
files: list[File] = [] |
|
|
json: list[dict] = [] |
|
|
|
|
|
|
|
|
json_list: list[dict] = [] |
|
|
|
|
|
|
|
|
agent_logs: list[AgentLogEvent] = [] |
|
|
agent_logs: list[AgentLogEvent] = [] |
|
|
agent_execution_metadata: Mapping[WorkflowNodeExecutionMetadataKey, Any] = {} |
|
|
agent_execution_metadata: Mapping[WorkflowNodeExecutionMetadataKey, Any] = {} |
|
|
|
|
|
|
|
|
if key in WorkflowNodeExecutionMetadataKey.__members__.values() |
|
|
if key in WorkflowNodeExecutionMetadataKey.__members__.values() |
|
|
} |
|
|
} |
|
|
if message.message.json_object is not None: |
|
|
if message.message.json_object is not None: |
|
|
json.append(message.message.json_object) |
|
|
|
|
|
|
|
|
json_list.append(message.message.json_object) |
|
|
elif message.type == ToolInvokeMessage.MessageType.LINK: |
|
|
elif message.type == ToolInvokeMessage.MessageType.LINK: |
|
|
assert isinstance(message.message, ToolInvokeMessage.TextMessage) |
|
|
assert isinstance(message.message, ToolInvokeMessage.TextMessage) |
|
|
stream_text = f"Link: {message.message.text}\n" |
|
|
stream_text = f"Link: {message.message.text}\n" |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
) |
|
|
) |
|
|
# Step 2: normalize JSON into {"data": [...]}.change json to list[dict] |
|
|
# Step 2: normalize JSON into {"data": [...]}.change json to list[dict] |
|
|
if json: |
|
|
|
|
|
json_output.extend(json) |
|
|
|
|
|
|
|
|
if json_list: |
|
|
|
|
|
json_output.extend(json_list) |
|
|
else: |
|
|
else: |
|
|
json_output.append({"data": []}) |
|
|
json_output.append({"data": []}) |
|
|
|
|
|
|