o ik@sddlZddlmZddlmZddlZddlmZddlmZddl m Z ddl m Z ddl m Z dd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZeeZdefddZdeeeffddZ e!didedeefddZ"dOdede#edffddZ$dd Z%d!d"Z&d#d$Z'd%d&Z(d'd(Z)d)d*Z*d+d,Z+d-d.Z,d/d0Z-d1d2Z.d3d4Z/d5d6Z0d7d8Z1d9d:Z2d;d<Z3d=d>Z4d?d@Z5dAdBZ6dCdDZ7dPdFe8fdGdHZ9dPdFe8fdIdJZ:dKdLZ;dMdNZ=0.1rrrrr_supported_versionssr langchaininstancecCs&dD]}t||rt||SqdS)z+Extract model name or ID from llm instance.)model model_namemodel_id model_keyrepo_idN)hasattrr)rattrrrr_extract_model_name#s  r"revent_idargs.cCs@t||}t|dkr|D] }t|jtr|jqdSdS)Nr)rdispatch_with_resultslenvalues isinstancevalue Exception)r#r$resulteventrrr_raising_dispatch+s    r-c Cs|j}tj}t|}t||dd}|jd|j|jjfdd|||d}d} | ||| ||z=zt d|f||i|} t d|| fWntyX|jtwW|j|d <|j|||| dd || S|j|d <|j|||| dd |w) Nrprompts%s.%sTllmsubmit_to_llmobsinterface_typeproviderrrzlangchain.llm.generate.beforezlangchain.llm.generate.after_dd.identifying_paramsr$kwargsresponse operation) _llm_typer_datadog_integrationr"r trace __module__ __class____name__record_instancellmobs_set_prompt_tagr-rdispatchr* set_exc_infosysexc_info_identifying_paramsllmobs_set_tagsfinish) funcrr$r7 llm_provider integrationrr.span completionsrrrtraced_llm_generate4s>       rNc s|j}t||dd}tj}t|}|jd|j|jjfdd|||d}| ||| ||d} z@zt d|f||i|IdH} t d|| fWnty\|jtwW|j|d <|j|||| dd || S|j|d <|j|||| dd |w) Nrr.r/Tr0r1zlangchain.llm.agenerate.beforezlangchain.llm.agenerate.afterr5r6)r:r rr;r"r<r=r>r?r@rAr-rrBr*rCrDrErFrGrH) rIrr$r7rJr.rKrrLrMrrrtraced_llm_agenerateTs@      rOc Cs |jdd}t||dd}tj}|jd|j|jjfdd|t ||d}| ||| ||d}z=zt d|f||i|}t d ||fWnty[|jtwW|j|d <|j||||d d ||S|j|d <|j||||d d |w) N-rmessagesr/T chat_modelr1z#langchain.chatmodel.generate.beforez"langchain.chatmodel.generate.afterr5chatr6r:splitr rr;r<r=r>r?r"r@rAr-rrBr*rCrDrErFrGrH rIrr$r7rJ chat_messagesrKrLchat_completionsrrrtraced_chat_model_generatets<      rYc s|jdd}t||dd}tj}|jd|j|jjfdd|t ||d}| ||| ||d}z@zt d|f||i|IdH}t d ||fWnty_|jtwW|j|d <|j||||d d ||S|j|d <|j||||d d |w) NrPrrQr/TrRr1z$langchain.chatmodel.agenerate.beforez#langchain.chatmodel.agenerate.afterr5rSr6rTrVrrrtraced_chat_model_agenerates>      rZc Cstj}|jd|j|jjdd|d}d}d}|||zLz+z t||dd}Wnt y8t||dd}Ynwt |t sA|g}||i|}Wnt yX|j twW|j|g||dd ||S|j|g||dd |w) a Traces the top level call of a LangChain Expression Language (LCEL) chain. LCEL is a new way of chaining in LangChain. It works by piping the output of one step of a chain into the next. This is similar in concept to the legacy LLMChain class, but instead relies internally on the idea of a RunnableSequence. It uses the operator `|` to create an implicit chain of `Runnable` steps. It works with a set of useful tools that distill legacy ways of creating chains, and various tasks and tooling within, making it preferable to LLMChain and related classes. This method captures the initial inputs to the chain, as well as the final outputs, and tags them appropriately. {}.{}Tchainr2r3rNrinputinputsr6rr;r<formatr=r>r?r@r r r(listr*rCrDrErGrHrIrr$r7rKrLr_ final_outputrrrtraced_lcel_runnable_sequences:      rec stj}|jd|j|jjdd|d}d}d}|||zOz.z t||dd}Wnt y9t||dd}Ynwt |t sB|g}||i|IdH}Wnt y\|j twW|j|g||dd ||S|j|g||dd |w) zS Similar to `traced_lcel_runnable_sequence`, but for async chaining calls. r[Tr\r]Nrr^r_r6r`rcrrr#traced_lcel_runnable_sequence_asyncs<     rfc sJtjdtffdd }dtffdd }t|d||dS)NrLc|dSNr@rLrrKrr_on_span_startedz-traced_chain_stream.._on_span_startedcs~jrjdnd}|r)tr)t|tjjr)|d}|jjdkr$t|}nt|}n d dd|D}j ||dddS)NJsonOutputParserrcSg|]}t|qSrstr.0chunkrrr zBtraced_chain_stream.._on_span_finished..r\r6) stepsrr(output_parsersror>r?rrrjoinrG)rLstreamed_chunks maybe_parserr+contentr$rrKr7rr_on_span_finisheds    z.traced_chain_stream.._on_span_finishedr\)rKrIrr$r7r3on_span_startedon_span_finished)rr;rr)rIrr$r7rlrrr~rtraced_chain_streamsrc ltjj}t}tdfdtffdd }dtffdd }t|d||||d S) Nz!langchain.chatmodel.stream.beforerLcrgrhrirjrkrrrl,rmz,traced_chat_stream.._on_span_startedcsRjd<t|r|d}|ddD]}||7}qng}j||dddS)Nr5rrSr6)rFr&rG)rLr{ joined_chunksrur~rrr/s  z-traced_chat_stream.._on_span_finishedrR rKrIrr$r7r3rrr4rrr;r:r"r-rr)rIrr$r7rJrrlrrr~rtraced_chat_stream%s$ rc r) Nzlangchain.llm.stream.beforerLcrgrhrirjrkrr_on_span_startUrmz)traced_llm_stream.._on_span_startcs6ddd|D}jd<j||dddS)NrcSrprrqrsrrrrvYrwz@traced_llm_stream.._on_span_finished..r5r0r6)rzrFrG)rLr{r}r~rrrXs z,traced_llm_stream.._on_span_finishedr0rr)rIrr$r7rJrrrrr~rtraced_llm_streamGs0 rc Cs>tj}t||dd}t||dddd}|jd|jjdd|d }|||d}i} z[z0d D] } t|| d} | | | <q.t|d i} | rG| | d <t|d g} | rS| | d <||i|}Wntyj|j t wW||ppi| psid }|j |g||dd| |S||pi| pid }|j |g||dd| wNrr^rrT)optionalz%stool)r3r2r)name descriptionmetadatatags)r^rinfor6rr;r r<__self__rr@rr*rCrDrErGrHrIrr$r7rK tool_inputrrL tool_output tool_info attributer)rr tool_inputsrrrtraced_base_tool_invokeksF        rc sFtj}t||dd}t||dddd}|jd|jjdd|d }|||d}i} z^z3d D] } t|| d} | | | <q/t|d i} | rH| | d <t|d g} | rT| | d <||i|IdH}Wntyn|j t wW||pti| pwid }|j |g||dd| |S||pi| pid }|j |g||dd| wrrrrrrtraced_base_tool_ainvokesH        rcCs@tj}|jdur||i|S||i|}||||||S)zy No actual tracing happens here--we just need to move the prompt template to somewhere it can be accessed later. Frr;llmobs_enabledhandle_prompt_template_invokerIrr$r7rKpromptrrr#patched_base_prompt_template_invokes  rcsNtj}|jdur||i|IdHS||i|IdH}||||||S)zD async version of above patched_base_prompt_template_invoke FNrrrrr$patched_base_prompt_template_ainvokes rcCs>tj}|jdur||i|S||||||i|}|S)a Wrapper for BaseLLM.invoke() and BaseChatModel.invoke() methods to handle prompt template metadata transfer. BaseLLM.invoke() wraps BaseLLM.generate(), converting .invoke()'s input (often a PromptValue with templating information) into a string. While most tagging happens in the .generate() wrapper, we need to enter here to capture that templating information before it is consumed. Since child spans may need to read the tagged data, we must tag before calling the wrapped function. Frr;rhandle_llm_invokerIrr$r7rKr8rrrpatched_language_model_invokes  rcsLtj}|jdur||i|IdHS||||||i|IdH}|S)z> async version of above patched_language_model_invoke FNrrrrrpatched_language_model_ainvokes rc Cs|jjdd}|dkr|jdkr||i|Stj}|jd|j|jjfdd|t||d}| ||d}z*z ||i|}Wnt yS|j t wW|j||||dd ||S|j||||dd |w) N Embeddingsropenai embed_queryr/T embeddingr1r6)r>r?rUlowerrr;r<r=r"r@r*rCrDrErGrH)rIrr$r7r4rKrL embeddingsrrrtraced_embeddings4   rc Cstj}|jj}|jd|j|jjfdd||d}|||g}z*z ||i|}Wnty;|j t wW|j ||||dd| |S|j ||||dd| w)Nr/Tsimilarity_search)r2r3r4r retrievalr6)rr;r>r?rr<r=r@r*rCrDrErGrH)rIrr$r7rKr4rL documentsrrrtraced_similarity_searchs.    rcCs||i||j}z-t|dd}|rt|st|dtt|dd}|r2t|s5t|dtWdSWdSWdStyItdt|YdSw)Nembed_documentsrz-Unable to patch LangChain Embeddings class %s) rrr rrr*logwarningrr)rIrr$r7clsrrrrr patched_embeddings_init_subclass)s      rcCsp||i||j}zt|dd}|r t|s#t|dtWdSWdSWdSty7tdt|YdSw)Nrz.Unable to patch LangChain VectorStore class %s) rrr rrr*rrrr)rIrr$r7rmethodrrr!patched_vectorstore_init_subclass9s   rFis_batchcfdd}|S)Nc stj}t|dd}|jjd|j}r|r|dn|}n|p"|}|j|d|d}|||d} z)z||i|} | WW|j|||| dd|St y\|j t w|j|||| dd|wNr._batchT)r2rrunnable_lambdar6 rr;rr>r?r<r@rGrHr*rCrDrE rIrr$r7rK instance_name default_name span_namerLr+rrr_traced_runnable_lambda_implFs0     zFtraced_runnable_lambda_operation.._traced_runnable_lambda_implrrrrrr traced_runnable_lambda_operationE rcr)Nc stj}t|dd}|jjd|j}r |r|dn|}n|p#|}|j|d|d}|||d} z,z||i|IdH} | WW|j|||| dd|St y`|j t w|j|||| dd|wrrrrrrrhs2     zLtraced_runnable_lambda_operation_async.._traced_runnable_lambda_implrrrrr&traced_runnable_lambda_operation_asyncgrrc CsttddrdSdt_ttjd}|t_ddlm}ddl m }ddl m }dd l m}dd lm}dd lm}dd lm}dd lm}t|dtt|dtt|dtt|dtt|dtt|dtt|dtt|dtt|dtt|dtt|dtt|dtt|dtt|dt t|dtt|dt t|dt!t|dt!t|dt"ddt|dt#ddt|dt"ddt|dt#ddt|dt$t|dt%t|dt&t|dt't|dt(t|dt)t*+dt,dS)N_datadog_patchFT)integration_configr)r) BaseChatModel)BaseLLM)BasePromptTemplate)RunnableLambda)RunnableSequence)BaseTool) VectorStoregenerate agenerateinvokeainvokestreamastreambatchabatchr__init_subclass__zlangchain.patch)-rrrr rrr;langchain_core.embeddingsr*langchain_core.language_models.chat_modelsr#langchain_core.language_models.llmsrlangchain_core.prompts.baserlangchain_core.runnables.baserrlangchain_core.toolsrlangchain_core.vectorstoresrrrNrOrrrrYrZrrerfrrrrrrrrrrrBtuple) rKrrrrrrrrrrrpatchsT                                  rcCsttddsdSdt_ttjjjdttjjjdttjjjdttjjjdttjjjdttjjjdttjjjdttjjjdttj j j dttj j j dttj j j dttj j j dttj j j d ttj j j d ttj j j dttj j j dttj j j dttj j j dttjjjd ttjjjd ttjjjd ttjjjd ttj jdttj jdttjj jdttjj jdttjjd ttjjd td tdS) NrFrrrrrrrrrzlangchain.unpatch)rrrrlanguage_modelsllmsr chat_modelsr runnablesbaserrtoolsrr.rrr vectorstoresrrrBrrrrrunpatchs@ r)r)F)=rDtypingrrrddtracer(ddtrace.contrib.internal.langchain.utilsr$ddtrace.contrib.internal.trace_utilsrrddtrace.internalrddtrace.internal.compatr ddtrace.internal.loggerr ddtrace.internal.utilsr r ddtrace.llmobs._integrationsr ddtrace.llmobs._utilsr ddtrace.tracerr?rrrrdictr_addr"rr-rNrOrYrZrerfrrrrrrrrrrrrrboolrrrrrrrrsZ                  *!("$''    "" 7