f3fi dZddlmZddlmZddlmZmZmZm Z ddl m Z m Z ddl mZddlmZddlmZerdd lmZmZd aGd d eZy )z'Callback Handler that writes to a file.) annotations)Path) TYPE_CHECKINGAnyTextIOcast)Selfoverride)warn_deprecated)BaseCallbackHandler) print_text) AgentAction AgentFinishFcJeZdZdZ d ddZddZ ddZddZddZ d ddZ e dd Z e dd Z e d dd Z e d dd Ze d dd Ze d ddZy)FileCallbackHandleraCallback Handler that writes to a file. This handler supports both context manager usage (recommended) and direct instantiation (deprecated) for backwards compatibility. Examples: Using as a context manager (recommended): ```python with FileCallbackHandler("output.txt") as handler: # Use handler with your chain/agent chain.invoke(inputs, config={"callbacks": [handler]}) ``` Direct instantiation (deprecated): ```python handler = FileCallbackHandler("output.txt") # File remains open until handler is garbage collected try: chain.invoke(inputs, config={"callbacks": [handler]}) finally: handler.close() # Explicit cleanup recommended ``` Args: filename: The file path to write to. mode: The file open mode. Defaults to `'a'` (append). color: Default color for text output. !!! note When not used as a context manager, a deprecation warning will be issued on first use. The file will be opened immediately in `__init__` and closed in `__del__` or when `close()` is called explicitly. Nc||_||_||_d|_t dt |jj |jd|_y)zInitialize the file callback handler. Args: filename: Path to the output file. mode: File open mode (e.g., `'w'`, `'a'`, `'x'`). Defaults to `'a'`. color: Default text color for output. Frzutf-8)encodingN)filenamemodecolor_file_opened_in_contextrropenfile)selfrrrs [/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/langchain_core/callbacks/file.py__init__zFileCallbackHandler.__init__;sP!   ',$    $ $TYY $ A  cd|_|S)aEnter the context manager. Returns: The FileCallbackHandler instance. !!! note The file is already opened in `__init__`, so this just marks that the handler is being used as a context manager. T)rrs r __enter__zFileCallbackHandler.__enter__Ps(,$ rc$|jy)aExit the context manager and close the file. Args: exc_type: Exception type if an exception occurred. exc_val: Exception value if an exception occurred. exc_tb: Exception traceback if an exception occurred. Nclose)rexc_typeexc_valexc_tbs r__exit__zFileCallbackHandler.__exit__^s  rc$|jy)z Destructor to cleanup when done.Nr"rs r__del__zFileCallbackHandler.__del__ns  rct|dr?|jr2|jjs|jjyyyy)zClose the file if it's open. This method is safe to call multiple times and will only close the file if it's currently open. rN)hasattrrclosedr#rs rr#zFileCallbackHandler.closers9 4 TYYtyy7G7G IIOO 8HY rc|jststddddat|dr"|j|jj r d}t |t||j||y) aWrite text to the file with deprecation warning if needed. Args: text: The text to write to the file. color: Optional color for the text. Defaults to `self.color`. end: String appended after the text. file: Optional file to write to. Defaults to `self.file`. Raises: RuntimeError: If the file is closed or not available. z0.3.67Tz{Using FileCallbackHandler without a context manager is deprecated. Use 'with FileCallbackHandler(...) as handler:' instead.)sincependingmessagerNz?File is not open. Use FileCallbackHandler as a context manager.)rrend)r_GLOBAL_DEPRECATION_WARNEDr r+rr, RuntimeErrorr )rtextrr1msgs r_writezFileCallbackHandler._write|sl&++4N )  *. &tV$ (9TYY=M=MSCs# #4diiu#>rc |jdxs*|jd|jddgdxsd}|jd|ddy ) zPrint that we are entering a chain. Args: serialized: The serialized chain information. inputs: The inputs to the chain. **kwargs: Additional keyword arguments that may contain `'name'`. nameidz z > Entering new z chain... r1N)getr6)r serializedinputskwargsr8s ron_chain_startz"FileCallbackHandler.on_chain_starts^ JJv  ~~fjnnTK=&I"&MN  )$y9t Drc *|jddy)zPrint that we finished a chain. Args: outputs: The outputs of the chain. **kwargs: Additional keyword arguments. z > Finished chain.r;r<Nr6)routputsr@s r on_chain_endz FileCallbackHandler.on_chain_ends )t 4rc Z|j|j|xs |jy)a'Handle agent action by writing the action log. Args: action: The agent action containing the log to write. color: Color override for this specific output. If `None`, uses `self.color`. **kwargs: Additional keyword arguments. )rNr6logr)ractionrr@s ron_agent_actionz#FileCallbackHandler.on_agent_actions! FJJe&9tzz :rc ||jd||j|||jd|yy)aHandle tool end by writing the output with optional prefixes. Args: output: The tool output to write. color: Color override for this specific output. If `None`, uses `self.color`. observation_prefix: Optional prefix to write before the output. llm_prefix: Optional prefix to write after the output. **kwargs: Additional keyword arguments. Nr;rC)routputrobservation_prefix llm_prefixr@s r on_tool_endzFileCallbackHandler.on_tool_endsI(  ) KK"/01 2 F  ! KK"ZL) * "rc H|j||xs |j|y)a Handle text output. Args: text: The text to write. color: Color override for this specific output. If `None`, uses `self.color`. end: String appended after the text. **kwargs: Additional keyword arguments. rr1N)r6r)rr4rr1r@s ron_textzFileCallbackHandler.on_texts D 3 =rc \|j|j|xs |jdy)a.Handle agent finish by writing the finish log. Args: finish: The agent finish object containing the log to write. color: Color override for this specific output. If `None`, uses `self.color`. **kwargs: Additional keyword arguments. r;rQNrG)rfinishrr@s ron_agent_finishz#FileCallbackHandler.on_agent_finishs# FJJe&9tzzt Dr)aN)rstrrrWr str | NonereturnNone)rYr )r$ztype[BaseException] | Noner%zBaseException | Noner&objectrYrZ)rYrZ)N)r4rWrrXr1rWrYrZ)r>dict[str, Any]r?r]r@rrYrZ)rDr]r@rrYrZ)N)rIrrrXr@rrYr)NNN) rLrWrrXrMrXrNrXr@rrYrZ) r4rWrrXr1rWr@rrYrZ)rTrrrXr@rrYrZ)__name__ __module__ __qualname____doc__rr r'r)r#r6r rArErJrOrRrUrrrrs#LCG  #& 5?  * ,&    ! #?#?#? #?  #?JE(E2@ELOE EE$557; ;! ;*4 ;GJ ;  ; ;!)-!% +++' +  +  + ++2>@ > > * >8; >LO >  > >7; E! E*4 EGJ E  E ErrN)ra __future__rpathlibrtypingrrrrtyping_extensionsr r langchain_core._apir langchain_core.callbacksr langchain_core.utils.inputr langchain_core.agentsrrr2rrbrrrks?-"33,/81>#pE-pEr