Skip to content

Commit 6d04118

Browse files
committed
Bug fixes
1 parent 03e4078 commit 6d04118

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/agentex/lib/sdk/fastacp/base/base_acp_server.py

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -363,8 +363,13 @@ async def message_send_wrapper(params: SendMessageParams):
363363
else:
364364
# The client wants streaming, but the function is not an async generator, so we turn it into one and yield each TaskMessageContent as a StreamTaskMessageFull which will be streamed to the client by the Agentex server.
365365
task_message_content_response = await fn(params)
366-
if isinstance(task_message_content_response, list):
367-
task_message_content_list = task_message_content_response
366+
367+
# Handle None returns gracefully - treat as empty list
368+
if task_message_content_response is None:
369+
task_message_content_list = []
370+
elif isinstance(task_message_content_response, list):
371+
# Filter out None values from lists
372+
task_message_content_list = [content for content in task_message_content_response if content is not None]
368373
else:
369374
task_message_content_list = [task_message_content_response]
370375

0 commit comments

Comments
 (0)