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

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

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

6
adapter.py
View File

@ -193,12 +193,12 @@ class OpenClawA2AExecutor(AgentExecutor):
self._heartbeat = heartbeat self._heartbeat = heartbeat
async def execute(self, context, event_queue): async def execute(self, context, event_queue):
from a2a.utils import new_agent_text_message from a2a.helpers import new_text_message
user_message = extract_message_text(context) user_message = extract_message_text(context)
if not user_message: if not user_message:
await event_queue.enqueue_event(new_agent_text_message("No message provided")) await event_queue.enqueue_event(new_text_message("No message provided"))
return return
await set_current_task(self._heartbeat, brief_task(user_message)) await set_current_task(self._heartbeat, brief_task(user_message))
@ -237,7 +237,7 @@ class OpenClawA2AExecutor(AgentExecutor):
finally: finally:
await set_current_task(self._heartbeat, "") await set_current_task(self._heartbeat, "")
await event_queue.enqueue_event(new_agent_text_message(reply)) await event_queue.enqueue_event(new_text_message(reply))
async def cancel(self, context, event_queue): # pragma: no cover async def cancel(self, context, event_queue): # pragma: no cover
pass pass