@@ -202,7 +202,6 @@ async def _run_async_impl(
202202 print ("Agent supports streaming, using streaming API" )
203203 # Process with streaming
204204 try :
205- # Criar a requisição usando o método correto de tasks/sendSubscribe
206205 request = SendTaskStreamingRequest (
207206 method = "tasks/sendSubscribe" , params = task_params
208207 )
@@ -217,7 +216,6 @@ async def _run_async_impl(
217216 )
218217 response .raise_for_status ()
219218
220- # Processar manualmente a resposta SSE
221219 async for line in response .aiter_lines ():
222220 if line .startswith ("data:" ):
223221 data = line [5 :].strip ()
@@ -279,8 +277,6 @@ async def _run_async_impl(
279277 print (
280278 f"Error in direct streaming: { str (stream_error )} , falling back to regular API"
281279 )
282- # If streaming fails, fall back to regular API
283- # Criar a requisição usando o método correto de tasks/send
284280 fallback_request = SendTaskRequest (
285281 method = "tasks/send" , params = task_params
286282 )
@@ -340,7 +336,6 @@ async def _run_async_impl(
340336 print ("Agent does not support streaming, using regular API" )
341337 # Process with regular request
342338 try :
343- # Criar a requisição usando o método correto de tasks/send
344339 request = SendTaskRequest (method = "tasks/send" , params = task_params )
345340
346341 async with httpx .AsyncClient () as client :
0 commit comments