biUdZddlmZddlZddlZddlmZmZddlmZm Z ddl m Z ddl m Z dd lmZej eZiad ed <iad ed <dd ZddZddZ ddZ ddZddZy)z7Callback-based tracing for Google ADK agents and tools.) annotationsN)datetimetimezone)AnyOptionalget_current_run_tree)RunTree) convert_adk_content_to_langsmithz dict[str, tuple[RunTree, float]]_active_agent_runs_active_tool_runsctS)Nrr/home/obispo/Crisostomo_bridge/mision_env/lib/python3.12/site-packages/langsmith/integrations/google_adk/_hooks.py_get_parent_runrs  !!rc bt|dd}|syt|ddxsd}t}|sy tj}i}t|ddx}rUt|ddx} rF| D cgc]%} t| ddst| j'} } | rdj | |d <|j |d |tj|tj  } | j| |ft|<ycc} w#t$r"} tjd | Yd} ~ yd} ~ wwxYw)z&Create chain run for agent invocation. invocation_idN agent_namegoogle_adk_agent user_contentpartstext inputchaintznamerun_typeinputs start_timez Error in before_agent_callback: )getattrrtimestrrjoin create_childr fromtimestamprutcpostr Exceptionloggerwarning)callback_contextargskwargsrrparentr$r#rrp text_parts agent_runes rbefore_agent_callbackr8s0,otDM )<>TBTJ  F ?YY[ !#"#3^TJ J< J gt<>?s08D(C>;C>A+D>D D. D))D.cHt|dd}|sytj|d}|sy |\}}i}t|ddx}rt||d<|j |r|nd|j y#t $r"} tjd| Yd} ~ yd} ~ wwxYw)z End agent run with final output.rNfinal_responseoutput)outputszError in after_agent_callback: ) r%r popr endpatchr-r.r/) r0r1r2rrun_infor6_r<r:r7s rafter_agent_callbackrB:s,otDM !%%mT:H  > 1"$$%57GN N> N @ PGH  gd ; >8<==>sA A66 B!?BB!c t|ddxsdt|dt|}t|ddxst|j}t }|sy t j }|j |d|xsitj|tj} | j| |ft|<y#t$r"} tjd | Yd} ~ yd} ~ wwxYw) z!Create tool run before execution.function_call_idNtool_rAr!toolrr zError in before_tool_callback: )r%idtype__name__rr&r)rr*rr+r,rr-r.r/) rFr1 tool_context other_argsr2rD tool_namer3r$tool_runr7s rbefore_tool_callbackrNPs  0$7 1 2d8*Ab./ 0fd+BtDz/B/BI  F  >YY[ &&:2--jX\\J '   /7.D*+ >8<==>sA+C C3C..C3cDt|ddxsdt|dt|}tj|d}|sy |\}} t |t r=|} |j dd} | r$|j dxs|j dnd} n-t |trd |i} d} n|dt|i} d} ni} d} |j| | r t| nd |jy#t$r"} tjd | Yd} ~ yd} ~ wwxYw) zEnd tool run with response.rDNrErAis_errorFerrorr;content)r<rQzError in after_tool_callback: )r%rGrr= isinstancedictgetlistr'r>r?r-r.r/)rFr1rJ tool_responserKr2rDr@rMrAr<rP error_msgr7s rafter_tool_callbackrYks4  0$7 1 2d8*Ab./ 0!$$%5tr?r-rclear)rAruns rclear_active_runsr^s*//1 8C  GG/G * IIK)..0 8C  GG/G * IIK      s#"B.!"B=. B:9B:= C C )returnzOptional[RunTree])r0rr1rr2rr_None) rFrr1dict[str, Any]rJrrKrr2rr_r`)rFrr1rarJrrWrrKrr2rr_r`)r_r`)__doc__ __future__rloggingr&rrtypingrrlangsmith.run_helpersr langsmith.run_treesr _messagesr getLoggerrIr.r __annotations__rrr8rBrNrYr^rrrrks=" ' 6'7   8 $79496838"?B>,> >#>36>EH>TW> >6)= )= )=)= )=  )=  )= )=Xr