From b9206c5d87a778c3b023588a219ecc5ecd167177 Mon Sep 17 00:00:00 2001 From: "hanzhi.421" Date: Fri, 15 Aug 2025 18:16:24 +0800 Subject: [PATCH 1/2] fix(a2a): message id --- veadk/cli/services/vefaas/template/deploy.py | 3 ++- veadk/cloud/cloud_app.py | 9 +++++++++ 2 files changed, 11 insertions(+), 1 deletion(-) diff --git a/veadk/cli/services/vefaas/template/deploy.py b/veadk/cli/services/vefaas/template/deploy.py index 79b2ca2d..42301bc4 100644 --- a/veadk/cli/services/vefaas/template/deploy.py +++ b/veadk/cli/services/vefaas/template/deploy.py @@ -18,6 +18,7 @@ from veadk.cloud.cloud_agent_engine import CloudAgentEngine from fastmcp.client import Client +from veadk.cloud.cloud_app import get_message_id SESSION_ID = "cloud_app_test_session" USER_ID = "cloud_app_test_user" @@ -48,7 +49,7 @@ async def main(): query_example, SESSION_ID, USER_ID ) print(f"VeFaaS application ID: {cloud_app.vefaas_application_id}") - print(f"Message ID: {response_message.message_id}") + print(f"Message ID: {get_message_id(response_message)}") print( f"Response from {cloud_app.vefaas_endpoint}: {response_message.parts[0].root.text}" ) diff --git a/veadk/cloud/cloud_app.py b/veadk/cloud/cloud_app.py index db0aee08..54dc59df 100644 --- a/veadk/cloud/cloud_app.py +++ b/veadk/cloud/cloud_app.py @@ -189,3 +189,12 @@ async def message_send( # TODO(floritange): show error log on VeFaaS function print(e) return None + + +def get_message_id(message: Message): + """Get the messageId of the a2a message""" + if getattr(message, "messageId", None): + # Compatible with the messageId of the old version + return message.messageId + else: + return message.message_id From 2f051775da0e8dda4b0d977fd9c5ec9894c4497f Mon Sep 17 00:00:00 2001 From: "hanzhi.421" Date: Fri, 15 Aug 2025 18:21:42 +0800 Subject: [PATCH 2/2] fix(a2a): version --- pyproject.toml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index ea1cca09..1c7fc34c 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -12,9 +12,9 @@ authors = [ ] dependencies = [ "pydantic-settings>=2.10.1", # Config management - "a2a-sdk==0.3.1", # For Google Agent2Agent protocol + "a2a-sdk>=0.3.0", # For Google Agent2Agent protocol "deprecated>=1.2.18", - "google-adk==1.11.0", # For basic agent architecture + "google-adk>=1.10.0", # For basic agent architecture "litellm>=1.74.3", # For model inference "loguru>=0.7.3", # For better logging "openinference-instrumentation-google-adk>=0.1.1", # For OpenInference instrumentation