D_i SrSSKJr SSKrSSKJrJr \(a6SSKJr SSK J r SSK J r SSK Jr SS KJrJr SS KJr SS KJr SS KJrJrJr \R4"\5r"S S5r"SS5r"SS5r"SS5r "SS5r!"SS5r""SS\\\ \\!\"5r#"SS\#5r$"SS\!5r%\&\#\%-S-r'g)$Base callback handler for LangChain.) annotationsN) TYPE_CHECKINGAny)Sequence)UUID)RetryCallState)Self) AgentAction AgentFinish)Document) BaseMessage)ChatGenerationChunkGenerationChunk LLMResultc`\rSrSrSrSS.SSjjrSS.S SjjrSrg) RetrieverManagerMixinzMixin for Retriever callbacks.N parent_run_idc g)zRun when Retriever errors. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nselferrorrun_idrkwargss W/home/james-whalen/.local/lib/python3.13/site-packages/langchain_core/callbacks/base.pyon_retriever_error(RetrieverManagerMixin.on_retriever_errorc g)zRun when Retriever ends running. Args: documents: The documents retrieved. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)r documentsrrrs ron_retriever_end&RetrieverManagerMixin.on_retriever_end+r!r"r r BaseExceptionrrr UUID | Nonerrreturnr) r$Sequence[Document]rrrr)rrr*r)__name__ __module__ __qualname____firstlineno____doc__rr%__static_attributes__rr"rrrs~(&*     #      ,&*  %   #       r"rc\rSrSrSrSSS.S SjjrSS.S SjjrSS.S SjjrS rg) LLMManagerMixin=zMixin for LLM callbacks.N)chunkrc g)aRun on new output token. Only available when streaming is enabled. For both chat models and non-chat models (legacy LLMs). Args: token: The new token. chunk: The new generated chunk, containing content and other information. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)rtokenr5rrrs ron_llm_new_token LLMManagerMixin.on_llm_new_token@r!r"rc g)aRun when LLM ends running. Args: response: The response which was generated. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)rresponserrrs r on_llm_endLLMManagerMixin.on_llm_endUr!r"c g)zRun when LLM errors. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nrrs r on_llm_errorLLMManagerMixin.on_llm_errorfr!r"r) r7strr5,GenerationChunk | ChatGenerationChunk | Nonerrrr)rrr*r) r;rrrrr)rrr*rr') r,r-r.r/r0r8r<r?r1rr"rr3r3=s" ?C%)   <    #     4&*     #      ,&*     #       r"r3c\rSrSrSrSS.S SjjrSS.S SjjrSS.S SjjrSS.S SjjrS r g)ChainManagerMixinxzMixin for chain callbacks.Nrc g)zRun when chain ends running. Args: outputs: The outputs of the chain. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)routputsrrrs r on_chain_endChainManagerMixin.on_chain_end{r!r"c g)zRun when chain errors. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nrrs ron_chain_error ChainManagerMixin.on_chain_errorr!r"c g)zRun on agent action. Args: action: The agent action. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)ractionrrrs ron_agent_action!ChainManagerMixin.on_agent_actionr!r"c g)zRun on the agent end. Args: finish: The agent finish. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)rfinishrrrs ron_agent_finish!ChainManagerMixin.on_agent_finishr!r"r) rGdict[str, Any]rrrr)rrr*rr') rNr rrrr)rrr*r) rRr rrrr)rrr*r) r,r-r.r/r0rHrKrOrSr1rr"rrDrDxs$&*     #      ,&*     #      ,&*     #      ,&*     #       r"rDc`\rSrSrSrSS.SSjjrSS.S SjjrSrg) ToolManagerMixinzMixin for tool callbacks.Nrc g)zRun when the tool ends running. Args: output: The output of the tool. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)routputrrrs r on_tool_endToolManagerMixin.on_tool_endr!r"c g)zRun when tool errors. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nrrs r on_tool_errorToolManagerMixin.on_tool_errorr!r"r) rZrrrrr)rrr*rr')r,r-r.r/r0r[r^r1rr"rrWrWs~#&*     #      ,&*     #       r"rWc"\rSrSrSrSSSS.S SjjrSSSS.S SjjrSSSS.SSjjrSSSS.SSjjrSSSSS .SS jjr S r g)CallbackManagerMixinzMixin for callback manager.Nrtagsmetadatac g)aRun when LLM starts running. !!! warning This method is called for non-chat models (regular LLMs). If you're implementing a handler for a chat model, you should use `on_chat_model_start` instead. Args: serialized: The serialized LLM. prompts: The prompts. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. **kwargs: Additional keyword arguments. Nrr serializedpromptsrrrdrers r on_llm_start!CallbackManagerMixin.on_llm_startr!r"c JURRS3n[U5eaRun when a chat model starts running. !!! warning This method is called for chat models. If you're implementing a handler for a non-chat model, you should use `on_llm_start` instead. Args: serialized: The serialized chat model. messages: The messages. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. **kwargs: Additional keyword arguments. z) does not implement `on_chat_model_start` __class__r,NotImplementedError rrhmessagesrrrdrermsgs ron_chat_model_start(CallbackManagerMixin.on_chat_model_starts'8(())RS!#&&r"c g)aMRun when the Retriever starts running. Args: serialized: The serialized Retriever. query: The query. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. **kwargs: Additional keyword arguments. Nrrrhqueryrrrdrers ron_retriever_start'CallbackManagerMixin.on_retriever_start$r!r"c gaERun when a chain starts running. Args: serialized: The serialized chain. inputs: The inputs. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. **kwargs: Additional keyword arguments. Nrrrhinputsrrrdrers ron_chain_start#CallbackManagerMixin.on_chain_start;r!r"rrdrer~c g)agRun when the tool starts running. Args: serialized: The serialized chain. input_str: The input string. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. inputs: The inputs. **kwargs: Additional keyword arguments. Nr rrh input_strrrrdrer~rs r on_tool_start"CallbackManagerMixin.on_tool_startRr!r"r)rhrUri list[str]rrrr)rdlist[str] | Noneredict[str, Any] | Nonerrr*rrhrUrrzlist[list[BaseMessage]]rrrr)rdrrerrrr*r)rhrUrxrArrrr)rdrrerrrr*r)rhrUr~rUrrrr)rdrrerrrr*r)rhrUrrArrrr)rdrrerr~rrrr*r) r,r-r.r/r0rjrtryrrr1rr"rraras%&*!%*. "    #   (    D&*!%*.'"'*'  ' # ''('' 'J&*!%*. "    #   (    :&*!%*. "    #   (    :&*!%*.(, "    #   ( &     r"rac\rSrSrSrSS.S SjjrSS.S SjjrSSS.S SjjrS rg) RunManagerMixinilzMixin for run manager.Nrc g)zRun on an arbitrary text. Args: text: The text. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nr)rtextrrrs ron_textRunManagerMixin.on_textor!r"c gzRun on a retry event. Args: retry_state: The retry state. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. **kwargs: Additional keyword arguments. Nrr retry_staterrrs ron_retryRunManagerMixin.on_retryr!r"rdrec g)aOverride to define a handler for a custom event. Args: name: The name of the custom event. data: The data for the custom event. Format will match the format specified by the user. run_id: The ID of the run. tags: The tags associated with the custom event (includes inherited tags). metadata: The metadata associated with the custom event (includes inherited metadata). Nrrnamedatarrdrers ron_custom_eventRunManagerMixin.on_custom_eventr!r"r) rrArrrr)rrr*r rr rrrr)rrr*r)rrArrrrrdrrerrrr*r) r,r-r.r/r0rrrr1rr"rrrls &*     #      ,&*  #   #      ."&*.       (     r"rc\rSrSr%SrSrS\S'SrS\S'\SSj5r \SSj5r \SS j5r \SS j5r \SS j5r \SS j5r\SS j5rSrg)BaseCallbackHandlerirFbool raise_error run_inlinecg)z Whether to ignore LLM callbacks.Frrs r ignore_llmBaseCallbackHandler.ignore_llmr"cg)z"Whether to ignore retry callbacks.Frrs r ignore_retry BaseCallbackHandler.ignore_retryrr"cg)z"Whether to ignore chain callbacks.Frrs r ignore_chain BaseCallbackHandler.ignore_chainrr"cg)z"Whether to ignore agent callbacks.Frrs r ignore_agent BaseCallbackHandler.ignore_agentrr"cg)z&Whether to ignore retriever callbacks.Frrs rignore_retriever$BaseCallbackHandler.ignore_retrieverrr"cg)z'Whether to ignore chat model callbacks.Frrs rignore_chat_model%BaseCallbackHandler.ignore_chat_modelrr"cg)zIgnore custom event.Frrs rignore_custom_event'BaseCallbackHandler.ignore_custom_eventrr"rNr*r)r,r-r.r/r0r__annotations__rpropertyrrrrrrrr1rr"rrrs/K;J- r"rcr\rSrSrSrSSSS.SSjjrSSSS.SSjjrSSSS.S SjjrSSS .S!S jjrSSS .S"S jjr SSSS.S#S jjr SSS .S$S jjr SSS .S"Sjjr SSSSS.S%Sjjr SSS .S&SjjrSSS .S"SjjrSSS .S'SjjrSS.S(SjjrSSS .S)SjjrSSS .S*SjjrSSSS.S+SjjrSSS .S,SjjrSSS .S"SjjrSSS.S-SjjrSrg).AsyncCallbackHandleriz%Async callback handler for LangChain.Nrcc # g7f)aRun when the model starts running. !!! warning This method is called for non-chat models (regular LLMs). If you're implementing a handler for a chat model, you should use `on_chat_model_start` instead. Args: serialized: The serialized LLM. prompts: The prompts. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. **kwargs: Additional keyword arguments. Nrrgs rrj!AsyncCallbackHandler.on_llm_startcR# URRS3n[U5e7frmrnrqs rrt(AsyncCallbackHandler.on_chat_model_starts*8(())RS!#&&s%')r5rrdc # g7f)aRun on new output token. Only available when streaming is enabled. For both chat models and non-chat models (legacy LLMs). Args: token: The new token. chunk: The new generated chunk, containing content and other information. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rr7r5rrrdrs rr8%AsyncCallbackHandler.on_llm_new_tokenrr)rrdc # g7f)aRun when the model ends running. Args: response: The response which was generated. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rr;rrrdrs rr<AsyncCallbackHandler.on_llm_end2rrc # g7f)akRun when LLM errors. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. - response (LLMResult): The response which was generated before the error occurred. Nrrrrrrdrs rr?!AsyncCallbackHandler.on_llm_errorErrc # g7fr|rr}s rr#AsyncCallbackHandler.on_chain_startZrrc # g7f)aRun when a chain ends running. Args: outputs: The outputs of the chain. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rrGrrrdrs rrH!AsyncCallbackHandler.on_chain_endqrrc # g7f)aRun when chain errors. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nrrs rrK#AsyncCallbackHandler.on_chain_errorrrrc # g7f)afRun when the tool starts running. Args: serialized: The serialized tool. input_str: The input string. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. inputs: The inputs. **kwargs: Additional keyword arguments. Nrrs rr"AsyncCallbackHandler.on_tool_startrrc # g7f)aRun when the tool ends running. Args: output: The output of the tool. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rrZrrrdrs rr[ AsyncCallbackHandler.on_tool_endrrc # g7f)aRun when tool errors. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nrrs rr^"AsyncCallbackHandler.on_tool_errorrrc # g7f)zRun on an arbitrary text. Args: text: The text. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rrrrrdrs rrAsyncCallbackHandler.on_textrrrc # g7frrrs rrAsyncCallbackHandler.on_retryrrc # g7f)zRun on agent action. Args: action: The agent action. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rrNrrrdrs rrO$AsyncCallbackHandler.on_agent_actionrrc # g7f)zRun on the agent end. Args: finish: The agent finish. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rrRrrrdrs rrS$AsyncCallbackHandler.on_agent_finish rrc # g7f)aBRun on the retriever start. Args: serialized: The serialized retriever. query: The query. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. metadata: The metadata. **kwargs: Additional keyword arguments. Nrrws rry'AsyncCallbackHandler.on_retriever_start rrc # g7f)a Run on the retriever end. Args: documents: The documents retrieved. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nr)rr$rrrdrs rr%%AsyncCallbackHandler.on_retriever_end7rrc # g7f)aRun on retriever error. Args: error: The error that occurred. run_id: The run ID. This is the ID of the current run. parent_run_id: The parent run ID. This is the ID of the parent run. tags: The tags. **kwargs: Additional keyword arguments. Nrrs rr'AsyncCallbackHandler.on_retriever_errorJrrrc # g7f)aOverride to define a handler for custom events. Args: name: The name of the custom event. data: The data for the custom event. Format will match the format specified by the user. run_id: The ID of the run. tags: The tags associated with the custom event (includes inherited tags). metadata: The metadata associated with the custom event (includes inherited metadata). Nrrs rr$AsyncCallbackHandler.on_custom_event]rrr)rhrUrirrrrr)rdrrerrrr*Noner)r7rAr5rBrrrr)rdrrrr*r) r;rrrrr)rdrrrr*r) rr(rrrr)rdrrrr*r)rhrUr~rUrrrr)rdrrerrrr*r) rGrUrrrr)rdrrrr*r)rhrUrrArrrr)rdrrerr~rrrr*r) rZrrrrr)rdrrrr*r) rrArrrr)rdrrrr*rr) rNr rrrr)rdrrrr*r) rRr rrrr)rdrrrr*r)rhrUrxrArrrr)rdrrerrrr*r) r$r+rrrr)rdrrrr*r)rrArrrrrdrrerrrr*r)r,r-r.r/r0rjrtr8r<r?rrHrKrr[r^rrrOrSryr%rrr1rr"rrrs/&*!%*. "    #   (    D&*!%*.'"'*'  ' # ''('' 'F?C%)!%  <    #      8&*!%     #       0&*!%     #       6&*!%*. "    #   (    8&*!%     #       0&*!%     #       2&*!%*.(, "    #   ( &    <&*!%     #       0&*!%     #       0&*!%     #       0&*  #   #      ,&*!%     #       0&*!%     #       2&*!%*. "    #   (    8&*!%  %   #       0&*!%     #       2"&*.       (     r"rc\rSrSrSrSSSSSS.SSjjjrSSjrSSjr\SSj5r SSS jjr SS jr SSS jjr SSS jjr SSS jjrSSjrSSSjjrSSjrSrg)BaseCallbackManageriuz$Base callback manager for LangChain.N)rdinheritable_tagsreinheritable_metadatacXlU=(d /UlX0lU=(d /UlU=(d /UlU=(d 0UlU=(d 0Ulg)a*Initialize callback manager. Args: handlers: The handlers. inheritable_handlers: The inheritable handlers. parent_run_id: The parent run ID. tags: The tags. inheritable_tags: The inheritable tags. metadata: The metadata. inheritable_metadata: The inheritable metadata. Nhandlersinheritable_handlersrrdrrer)rrrrrdrrers r__init__BaseCallbackManager.__init__xsQ,4< &B !+8JB 0 6B B $8$>B!r"c `URURR5URR5URUR R5UR R5URR5URR5S9$)z&Return a copy of the callback manager.r) rorcopyrrrdrrerrs rrBaseCallbackManager.copys~~]]'')!%!:!:!?!?!A,,!!22779]]'')!%!:!:!?!?!A  r"c :[[UR5[UR5-5n[[UR5[UR5-5nUR UR =(d UR UU[[UR UR -55[[URUR-550UREURE0UREURES9$)aMerge the callback manager with another callback manager. May be overwritten in subclasses. Primarily used internally within merge_configs. Returns: The merged callback manager of the same type as the current object. Example: Merging two callback managers. ```python from langchain_core.callbacks.manager import ( CallbackManager, trace_as_chain_group, ) from langchain_core.callbacks.stdout import StdOutCallbackHandler manager = CallbackManager(handlers=[StdOutCallbackHandler()], tags=["tag2"]) with trace_as_chain_group("My Group Name", tags=["tag1"]) as group_manager: merged_manager = group_manager.merge(manager) print(merged_manager.handlers) # [ # , # , # ] print(merged_manager.tags) # ['tag2', 'tag1'] ``` )rrrrdrrer) listsetrrrorrdrrer)rothercombined_handlerscombined_inheritables rmergeBaseCallbackManager.mergesB!T]]!3c%..6I!IJ# )) *S1K1K-L L ~~,,C0C0C&!5c$))ejj012!#d&;&;e>T>T&T"UV--.."++",,"  r"cg)z&Whether the callback manager is async.Frrs ris_asyncBaseCallbackManager.is_asyncrr"cXR;aURRU5 U(a,XR;aURRU5 ggg)z|Add a handler to the callback manager. Args: handler: The handler to add. inherit: Whether to inherit the handler. N)rappendrrhandlerinherits r add_handlerBaseCallbackManager.add_handlersJ -- ' MM  ) w&?&??  % % , ,W 5@7r"cXR;aURRU5 XR;aURRU5 gg)zWRemove a handler from the callback manager. Args: handler: The handler to remove. N)rremover)rrs rremove_handler"BaseCallbackManager.remove_handlersE mm # MM  ) // /  % % , ,W 5 0r"cP/Ul/UlUHnURX2S9 M g)zSet handlers as the only handlers on the callback manager. Args: handlers: The handlers to set. inherit: Whether to inherit the handlers. rN)rrr)rrrrs r set_handlers BaseCallbackManager.set_handlerss. $&!G   W  6 r"c&URU/US9 g)zSet handler as the only handler on the callback manager. Args: handler: The handler to set. inherit: Whether to inherit the handler. rN)rrs r set_handlerBaseCallbackManager.set_handler s 7)W5r"cUH&nX0R;dMURU/5 M( URRU5 U(aURRU5 gg)znAdd tags to the callback manager. Args: tags: The tags to add. inherit: Whether to inherit the tags. N)rd remove_tagsextendr)rrdrtags radd_tagsBaseCallbackManager.add_tagssXCii  #'    ! ! ( ( . r"cUHYnX R;aURRU5 X R;dM>URRU5 M[ g)zLRemove tags from the callback manager. Args: tags: The tags to remove. N)rdr r)rrdrs rrBaseCallbackManager.remove_tags)sJ Cii   %+++%%,,S1 r"cURRU5 U(aURRU5 gg)z~Add metadata to the callback manager. Args: metadata: The metadata to add. inherit: Whether to inherit the metadata. N)reupdater)rrers r add_metadata BaseCallbackManager.add_metadata5s2 X&   % % , ,X 6 r"cUH;nURRUS5 URRUS5 M= g)zPRemove metadata from the callback manager. Args: keys: The keys to remove. N)repopr)rkeyskeys rremove_metadata#BaseCallbackManager.remove_metadataDs8 C MM  c4 (  % % ) )#t 4r")rrrrrerrd)NN)rlist[BaseCallbackHandler]rz list[BaseCallbackHandler] | Nonerr)rdrrrrerrrr*r)r*r )rrr*r r)T)rrrrr*r)rrr*r)rr&rrr*r)rdrrrr*r)rdrr*r)rerUrrr*r)r"rr*r)r,r-r.r/r0rrrrrrr rrrrrr$r1rr"rrrusb. BF%) ? "&-1*.6:?+???# ?  ?+?(?4? ?@  4 l6$66  6 67+77  7& 6$ 6 6  6 ///  /$ 2 7  7 7  75r"r)(r0 __future__rloggingtypingrrcollections.abcruuidrtenacityr typing_extensionsr langchain_core.agentsr r langchain_core.documentsr langchain_core.messagesrlangchain_core.outputsrrr getLoggerr,_LOGGERrr3rDrWrarrrrr Callbacksrr"rr5s*"%('&>13VV   H %# # L8 8 vE E P# # LC C L: : z1 1hU .U p W5.W5t $ %(; ;d B r"