Skip to content

Commit 5898802

Browse files
committed
Convert proto utils to work with UUID
1 parent d168b85 commit 5898802

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

src/a2a/utils/proto_utils.py

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,10 @@ def message(cls, message: types.Message | None) -> a2a_pb2.Message | None:
3232
if message is None:
3333
return None
3434
return a2a_pb2.Message(
35-
message_id=message.message_id,
35+
message_id=str(message.message_id),
3636
content=[ToProto.part(p) for p in message.parts],
37-
context_id=message.context_id or '',
38-
task_id=message.task_id or '',
37+
context_id=str(message.context_id) if message.context_id else None,
38+
task_id=str(message.task_id) if message.task_id else None,
3939
role=cls.role(message.role),
4040
metadata=ToProto.metadata(message.metadata),
4141
)
@@ -86,8 +86,8 @@ def file(
8686
@classmethod
8787
def task(cls, task: types.Task) -> a2a_pb2.Task:
8888
return a2a_pb2.Task(
89-
id=task.id,
90-
context_id=task.context_id,
89+
id=str(task.id),
90+
context_id=str(task.context_id),
9191
status=ToProto.task_status(task.status),
9292
artifacts=(
9393
[ToProto.artifact(a) for a in task.artifacts]
@@ -129,7 +129,7 @@ def task_state(cls, state: types.TaskState) -> a2a_pb2.TaskState:
129129
@classmethod
130130
def artifact(cls, artifact: types.Artifact) -> a2a_pb2.Artifact:
131131
return a2a_pb2.Artifact(
132-
artifact_id=artifact.artifact_id,
132+
artifact_id=str(artifact.artifact_id),
133133
description=artifact.description,
134134
metadata=ToProto.metadata(artifact.metadata),
135135
name=artifact.name,
@@ -155,7 +155,7 @@ def push_notification_config(
155155
else None
156156
)
157157
return a2a_pb2.PushNotificationConfig(
158-
id=config.id or '',
158+
id=str(config.id) if config.id else None,
159159
url=config.url,
160160
token=config.token,
161161
authentication=auth_info,
@@ -166,8 +166,8 @@ def task_artifact_update_event(
166166
cls, event: types.TaskArtifactUpdateEvent
167167
) -> a2a_pb2.TaskArtifactUpdateEvent:
168168
return a2a_pb2.TaskArtifactUpdateEvent(
169-
task_id=event.task_id,
170-
context_id=event.context_id,
169+
task_id=str(event.task_id),
170+
context_id=str(event.context_id),
171171
artifact=ToProto.artifact(event.artifact),
172172
metadata=ToProto.metadata(event.metadata),
173173
append=event.append or False,
@@ -179,8 +179,8 @@ def task_status_update_event(
179179
cls, event: types.TaskStatusUpdateEvent
180180
) -> a2a_pb2.TaskStatusUpdateEvent:
181181
return a2a_pb2.TaskStatusUpdateEvent(
182-
task_id=event.task_id,
183-
context_id=event.context_id,
182+
task_id=str(event.task_id),
183+
context_id=str(event.context_id),
184184
status=ToProto.task_status(event.status),
185185
metadata=ToProto.metadata(event.metadata),
186186
final=event.final,

0 commit comments

Comments
 (0)