a ag2 @szdZddlZddlZddlmZmZmZmZmZm Z ddl m Z m Z ddl mZddlmZeeZGdddeZdS) z-Chain that runs an arbitrary python function.N)Any AwaitableCallableDictListOptional)AsyncCallbackManagerForChainRunCallbackManagerForChainRun)Field)Chainc@s"eZdZUdZeeed<eeed<eddZe e eefge eeffed<edddZ e e e ee fgee ee ffed <eejedd d d Zeeed ddZeeed ddZde eefe ee eefdddZde ee fe ee ee fdddZdS)TransformChainaChain that transforms the chain output. Example: .. code-block:: python from langchain.chains import TransformChain transform_chain = TransformChain(input_variables=["text"], output_variables["entities"], transform=func()) input_variablesoutput_variablesZ transform)alias transform_cbNZ atransform atransform_cb)msgreturncCst|dS)z4Log a message once. :meta private: N)loggerwarning)rrh/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/langchain/chains/transform.py _log_once(szTransformChain._log_once)rcCs|jS)z3Expect input keys. :meta private: )r selfrrr input_keys1szTransformChain.input_keyscCs|jS)z4Return output keys. :meta private: )rrrrr output_keys9szTransformChain.output_keys)inputs run_managerrcCs ||S)N)rrrrrrr_callAszTransformChain._callcs2|jdur||IdHS|d||SdS)NzRTransformChain's atransform is not provided, falling back to synchronous transform)rrrrrrr_acallHs  zTransformChain._acall)N)N)__name__ __module__ __qualname____doc__rstr__annotations__r rrrrrrr staticmethod functools lru_cacherpropertyrrr r rr!rrrrr s2   , ,     r )r%r)loggingtypingrrrrrrZlangchain_core.callbacksrr Zpydanticr Zlangchain.chains.baser getLoggerr"rr rrrrs