o `+ iSA@s ddlmZddlZddlZddlZddlmZmZddlm Z m Z m Z m Z ddl mZddlmZmZmZddlmZmZmZmZmZddlmZdd lmZdd lmZdd lm Z dd l!m"Z"dd l#m$Z$ddl%m&Z&e rxddl'm(Z(m)Z)e*e+Z,GdddZ-dS)) annotationsN) AsyncIteratorIterator) TYPE_CHECKINGAnyOptionalUnion)UUID) AgentAction AgentFinish AgentStep)AsyncCallbackManagerAsyncCallbackManagerForChainRunCallbackManagerCallbackManagerForChainRun Callbacks)dumpd)RunInfo) AddableDict)BaseTool)get_color_mapping)RUN_KEY)asyncio_timeout) AgentExecutorNextStepOutputc@s6eZdZUdZ dKddddddddLddZded<d ed <d ed <ded <ded<ded<ded<ded<edMddZejdNddZedOdd Z e jdPd!d Z edQd#d$Z edMd%d&Z dRd'd(Z dRd)d*Z dSd0d1ZdTd4d5ZdUd7d8ZdVdysz:AgentExecutorIterator.name_to_tool_map..)r"toolsr4r-r-r.name_to_tool_mapvsz&AgentExecutorIterator.name_to_tool_mapcCstdd|jjDddgdS)z"A mapping of tool names to colors.cSsg|]}|jqSr-r9r;r-r-r. sz7AgentExecutorIterator.color_mapping..greenred)Zexcluded_colors)rr"r>r4r-r-r. color_mapping{sz#AgentExecutorIterator.color_mappingcCs*tdg|_d|_d|_t|_dS)z} Reset the iterator to its initial state, clearing intermediate steps, iterations, and time elapsed. z0(Re)setting AgentExecutorIterator to fresh statergN)loggerdebugintermediate_steps iterations time_elapsedtime start_timer4r-r-r.r+s zAgentExecutorIterator.resetcCs4|jd7_t|j|_td|j|jdS)zQ Increment the number of iterations and update the time elapsed. z$Agent Iterations: %s (%.2fs elapsed)N)rGrIrJrHrDrEr4r-r-r.update_iterationssz'AgentExecutorIterator.update_iterationsoutputsdict[str, Any] run_managerBUnion[CallbackManagerForChainRun, AsyncCallbackManagerForChainRun]rcCs2t|jj|j|dd}|jrt|jd|t<|S)NT)Zreturn_only_outputs)r)rr"Z prep_outputsr#r rrr)r,rMrOZprepared_outputsr-r-r.make_final_outputssz(AgentExecutorIterator.make_final_outputsr,Iterator[AddableDict]c csntd|t|j|jj|jj|j|jj|j |jj }|j t |j|j |j |jd}zm|j|j|jrg}|j|j|j|j |j|D]'}|||jrpt|trbt|g|jdVqIt|trpt|g|jdVqI|j|}||||}d|v}|jr|r|V|rWdS|j|j|js9Wnt y}z|!|d}~ww|"|VdS)Nz"Initialising AgentExecutorIteratorr9actionsmessagesZstepsrUintermediate_step)#rDrEr+r configurer$r"verboserron_chain_startrr#rr_should_continuerGrHZ_iter_next_stepr?rCrFappendr! isinstancer rrUr _consume_next_steprL_process_next_step_output BaseExceptionon_chain_error_stop r,Zcallback_managerrOZ next_step_seqchunkZ next_stepoutputis_finaler-r-r.__iter__sr        % zAgentExecutorIterator.__iter__AsyncIterator[AddableDict]c Cstd|t|j|jj|jj|j|jj|j |jj }|j t |j|j |j |jdIdH}zt|jj4IdH|j|j|jrg}|j|j|j|j |j|2z+3dHW}|||jrt|trtt|g|jdVqWt|trt|g|jdVqW6|j|}| |!||IdH}d|v}|jr|r|V|r WdIdHWdS|j|j|jsGWdIdHn 1IdHswYWn*t"t#j"fy|$|IdHVYdSt%y}z |&|IdHd}~ww|$|IdHVdS)z N.B. __aiter__ must be a normal method, so need to initialize async run manager on first __anext__ call where we can await it z*Initialising AgentExecutorIterator (async)r9NrSrVrW)'rDrEr+r rXr$r"rYrrrZrr#rrrZmax_execution_timer[rGrHZ_aiter_next_stepr?rCrFr\r!r]r rrUr r^rL_aprocess_next_step_output TimeoutErrorasyncio_astopr`rarcr-r-r. __aiter__s         (/zAgentExecutorIterator.__aiter__next_step_output1Union[AgentFinish, list[tuple[AgentAction, str]]]rcCstdt|trtd|j||dS|j|tdt|dkr<|d}|j |}|dur<|j||dSt |dS) zj Process the output of the next step, handling AgentFinish and tool return cases. z$Processing output of Agent loop stepzBHit AgentFinish: _return -> on_chain_end -> run final output logicrO+Updated intermediate_steps with step outputrKrNrW) rDrEr]r _returnrFextendlenr"_get_tool_returnrr,rorOZnext_step_actionZ tool_returnr-r-r.r_=s      z/AgentExecutorIterator._process_next_step_outputrcstdt|trtd|j||dIdHS|j|tdt|dkrC|d}|j |}|durC|j||dIdHSt |dS) zp Process the output of the next async step, handling AgentFinish and tool return cases. z*Processing output of async Agent loop stepzCHit AgentFinish: _areturn -> on_chain_end -> run final output logicrqNrrrKrrs) rDrEr]r _areturnrFrurvr"rwrrxr-r-r.rjYs      z0AgentExecutorIterator._aprocess_next_step_outputcCs8td|jjj|jj|jfi|j}|j||dS)zb Stop the iterator and raise a StopIteration exception with the stopped response. ;Stopping agent prematurely due to triggering stop conditionrq) rDwarningr" _action_agentreturn_stopped_responseearly_stopping_methodrFr#rtr,rOrer-r-r.rbus zAgentExecutorIterator._stopcs@td|jjj|jj|jfi|j}|j||dIdHS)zu Stop the async iterator and raise a StopAsyncIteration exception with the stopped response. rzrqN) rDr{r"r|r}r~rFr#ryrr-r-r.rms zAgentExecutorIterator._astoprer cCs4|jj||j|d}|j|d<|||||S)z: Return the final output of the iterator. rqrU)r"rtrFrU on_chain_endrQr,rerOZreturned_outputr-r-r.rts   zAgentExecutorIterator._returncsB|jj||j|dIdH}|j|d<||IdH|||S)z@ Return the final output of the async iterator. rqNrU)r"ryrFrUrrQrr-r-r.rys  zAgentExecutorIterator._areturnr7)r"rr#rr$rrr%rr&rr'rr(r r)r!r))r2r0)r#rr2r6)r2r)r"rr2r6)r2r8)r2r6)rMrNrOrPr2r)r,rr2rR)r2ri)rorprOrr2r)rorprOrr2r)rOrr2r)rOrr2r)rer rOrr2r)rer rOrr2r)__name__ __module__ __qualname____doc__r/__annotations__propertyr#setterr"r?rCr+rLrQrhrnr_rjrbrmrtryr-r-r-r.r*sT ,         ? P   r). __future__rrlloggingrIcollections.abcrrtypingrrrruuidr Zlangchain_core.agentsr r r Zlangchain_core.callbacksr rrrrZlangchain_core.load.dumprZlangchain_core.outputsrZlangchain_core.runnables.utilsrZlangchain_core.toolsrZlangchain_core.utils.inputrZlangchain.schemarZlangchain.utilities.asynciorZlangchain.agents.agentrr getLoggerrrDrr-r-r-r.s(