fix(a2a): message id and a2a version (#66)

* fix(a2a): message id

* fix(a2a): version

Author: zakahan

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

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}"
         )

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