removing changes related to a2a sdk issue

Author: rishikunnath2747

pyproject.toml

@@ -75,7 +75,7 @@ dev = [
     "sqlalchemy>=2.0.0",
     "django>=4.0",
     "flask>=3.0",
-    "a2a-sdk>=1.0.0",
+    "a2a-sdk>=0.2.0",
     "langchain-core>=1.2.7",
     "langgraph>=0.2.0",
     "langchain-community>=0.3.0",

src/sap_cloud_sdk/extensibility/client.py

@@ -12,10 +12,6 @@
 import httpx
 from a2a.types import Message
 from opentelemetry.propagate import inject
-
-from google.protobuf.json_format import MessageToDict as _proto_message_to_dict
-from google.protobuf.json_format import ParseDict as _proto_parse_dict
-
 from pydantic_core import ValidationError
 
 from sap_cloud_sdk.core.telemetry import Module, Operation
@@ -381,7 +377,7 @@ def call_hook(
                         .get("main", [[{}]])[0][0]
                         .get("json", {})
                     )
-                    return _proto_parse_dict(response_json, Message())
+                    return Message(**response_json)
                 except (KeyError, IndexError, TypeError, ValidationError) as exc:
                     raise ExtensibilityError(
                         f"Failed to extract response from last executed node: {exc}"
@@ -450,10 +446,7 @@ async def _execute_workflow_via_agw(
         message: Optional[Any],
         headers: Optional[dict],
     ) -> tuple[str, Any]:
-        if message is None:
-            message_body: dict = {}
-        else:
-            message_body = _proto_message_to_dict(message, preserving_proto_field_name=True)
+        message_body = message.model_dump(mode="json") if message is not None else {}
         execute_arguments = {
             "workflowId": hook.n8n_workflow_config.workflow_id,
             "inputs": {
@@ -507,7 +500,7 @@ def _extract_message(data: dict) -> Message:
                 .get("main", [[{}]])[0][0]
                 .get("json", {})
             )
-            return _proto_parse_dict(response_json, Message())
+            return Message(**response_json)
         except (KeyError, IndexError, TypeError, ValidationError) as exc:
             raise TransportError(
                 f"Failed to extract response from last executed node: {exc}"