@@ -100,7 +100,7 @@ def get_function_response(event: Event, function_call_id: str) -> types.Function
100100
101101 print ("\n Running agent..." )
102102 events_async = runner .run_async (
103- session_id = session .id , user_id = 'user' , new_message = content
103+ session_id = session .id , user_id = USER_ID , new_message = content
104104 )
105105
106106
@@ -112,7 +112,7 @@ def get_function_response(event: Event, function_call_id: str) -> types.Function
112112 else :
113113 long_running_function_response = get_function_response (event , long_running_function_call .id )
114114 if long_running_function_response :
115- ticket_id = long_running_function_response .response ['ticket_id ' ]
115+ ticket_id = long_running_function_response .response ['ticket-id ' ]
116116 if event .content and event .content .parts :
117117 if text := '' .join (part .text or '' for part in event .content .parts ):
118118 print (f'[{ event .author } ]: { text } ' )
@@ -124,7 +124,7 @@ def get_function_response(event: Event, function_call_id: str) -> types.Function
124124 updated_response = long_running_function_response .model_copy (deep = True )
125125 updated_response .response = {'status' : 'approved' }
126126 async for event in runner .run_async (
127- session_id = session .id , user_id = 'user' , new_message = types .Content (parts = [types .Part (function_response = updated_response )], role = 'user' )
127+ session_id = session .id , user_id = USER_ID , new_message = types .Content (parts = [types .Part (function_response = updated_response )], role = 'user' )
128128 ):
129129 if event .content and event .content .parts :
130130 if text := '' .join (part .text or '' for part in event .content .parts ):
0 commit comments