@@ -337,26 +337,15 @@ def _create_a2a_request_for_user_function_response(
337337 ctx .session .events [- 1 ], ctx , Role .user , self ._genai_part_converter
338338 )
339339 if function_call_event .custom_metadata :
340- a2a_message .task_id = (
341- function_call_event .custom_metadata .get (
342- A2A_METADATA_PREFIX + "task_id"
343- )
344- if function_call_event .custom_metadata
345- else None
346- )
347- a2a_message .context_id = (
348- function_call_event .custom_metadata .get (
349- A2A_METADATA_PREFIX + "context_id"
350- )
351- if function_call_event .custom_metadata
352- else None
353- )
340+ metadata = function_call_event .custom_metadata
341+ a2a_message .task_id = metadata .get (A2A_METADATA_PREFIX + "task_id" )
342+ a2a_message .context_id = metadata .get (A2A_METADATA_PREFIX + "context_id" )
354343
355344 return a2a_message
356345
357346 def _construct_message_parts_from_session (
358347 self , ctx : InvocationContext
359- ) -> tuple [list [A2APart ], dict [str , Any ], str ]:
348+ ) -> tuple [list [A2APart ], Optional [str ] ]:
360349 """Construct A2A message parts from session events.
361350
362351 Args:
@@ -374,11 +363,8 @@ def _construct_message_parts_from_session(
374363 # stop on content generated by current a2a agent given it should already
375364 # be in remote session
376365 if event .custom_metadata :
377- context_id = (
378- event .custom_metadata .get (A2A_METADATA_PREFIX + "context_id" )
379- if event .custom_metadata
380- else None
381- )
366+ metadata = event .custom_metadata
367+ context_id = metadata .get (A2A_METADATA_PREFIX + "context_id" )
382368 break
383369
384370 if not event .content or not event .content .parts :
0 commit comments