molecule-ai/molecule-ai-workspace-template-gemini-cli
35
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #10 from Molecule-AI/fix/a2a-sdk-v1-symbol-rename

Browse Source 
fix: rename new_agent_text_message → new_text_message (a2a-sdk v1)
This commit is contained in:
Hongming Wang 2026-04-29 00:43:54 -07:00 committed by GitHub
commit 87a6fcf7ef
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
cli_executor.py
View File

@ -36,7 +36,7 @@ from pathlib import Path
from a2a.server.agent_execution import AgentExecutor, RequestContext
from a2a.server.events import EventQueue
# KI-009: a2a-sdk v1 renames a2a.utils → a2a.helpers
from a2a.helpers import new_agent_text_message
from a2a.helpers import new_text_message
from molecule_runtime.config import RuntimeConfig
from molecule_runtime.executor_helpers import (
@ -276,7 +276,7 @@ class CLIAgentExecutor(AgentExecutor):
user_input = extract_message_text(context.message)
if not user_input:
await event_queue.enqueue_event(
new_agent_text_message("Error: message contained no text content.")
new_text_message("Error: message contained no text content.")
)
return
@ -368,7 +368,7 @@ class CLIAgentExecutor(AgentExecutor):
result = stdout_text
if result:
await event_queue.enqueue_event(
new_agent_text_message(result)
new_text_message(result)
)
return
else:
@ -380,7 +380,7 @@ class CLIAgentExecutor(AgentExecutor):
await asyncio.sleep(delay)
continue
await event_queue.enqueue_event(
new_agent_text_message("(no response generated after retries)")
new_text_message("(no response generated after retries)")
)
return
else:
@ -402,7 +402,7 @@ class CLIAgentExecutor(AgentExecutor):
# only the sanitized category to the user.
logger.error("CLI agent error [%s]: %s", self.runtime, error_msg[:500])
await event_queue.enqueue_event(
new_agent_text_message(sanitize_agent_error(category=category))
new_text_message(sanitize_agent_error(category=category))
)
return
@ -424,13 +424,13 @@ class CLIAgentExecutor(AgentExecutor):
except Exception as wait_err:
logger.warning("CLI wait error: %s", wait_err)
await event_queue.enqueue_event(
new_agent_text_message(sanitize_agent_error(category="timeout"))
new_text_message(sanitize_agent_error(category="timeout"))
)
return
except Exception as exc:
logger.exception("CLI agent exception [%s]", self.runtime)
await event_queue.enqueue_event(
new_agent_text_message(sanitize_agent_error(exc))
new_text_message(sanitize_agent_error(exc))
)
return