o ]+ ij@sNddlmZddlZddlZddlZddlZddlmZddlm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZdd lmZmZmZe rVdd lmZe d ed e fd ZeeZ dddZ#d?ddZ$d@ddZ%dAd"d#Z&dBd&d'Z'  (dCdDd1d2Z(Gd3d4d4ed(d5Z)edd6d7dEd:d;Z*dS)F) annotationsN)Mapping) TYPE_CHECKINGAnyCallableOptionalTypeVarUnion) TypedDict)client) run_helpers) warn_beta)InputTokenDetailsOutputTokenDetails UsageMetadata)genaiCz genai.Client)boundddictreturncCsdd|DS)z#Remove None values from dictionary.cSi|] \}}|dur||qSN.0kvrrf/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/langsmith/wrappers/_gemini.py !z_strip_none..)items)rrrr _strip_nonesr"kwargsNonecCs2d|vrt|dtst|d|d<dSdSdS)zBConvert GenerateContentConfig to dict for LangSmith compatibility.configN) isinstancervars)r#rrr_convert_config_for_tracing$sr(inputsc Cs|d}|s |St|tr#d|dg|dddd|DSt|trYtdd |DrHd d |D|ddd d|DSg}|D]}t|trG|d d}|dg}g}g}|D]}t|trd|vr|dr||d|d|ddqfd|vr|d} | dd} | dd} t| trt |  d} n| } |dd| d| dddqfd|vr|d} |d| d| d id!d"qfd#|vsd$|vr|d#p|d$}|d%urt|ts| }|d#|d&|d|d'id(d)qft|tr$|||d|dqf|r8td*d |Dr8d+ |}n|r=|nd,}|||dqL||ddd-d|DS|S).uProcess Gemini inputs to normalize them for LangSmith tracing. Example: {"contents": "Hello", "model": "gemini-pro"} → {"messages": [{"role": "user", "content": "Hello"}], "model": "gemini-pro"} {"contents": [{"role": "user", "parts": [{"text": "What is AI?"}]}], "model": "gemini-pro"} → {"messages": [{"role": "user", "content": "What is AI?"}], "model": "gemini-pro"} contentsuserrolecontentmodel)messagesr/cSi|] \}}|dvr||qS)r*r/rrrrrr=r z*_process_gemini_inputs..css|]}t|tVqdSr)r&strritemrrr Csz)_process_gemini_inputs..cSsg|]}d|dqS)r+r,rr4rrr Fsz*_process_gemini_inputs..cSr1r2rrrrrrHr r-partstexttyper9 inline_data mime_type image/jpegdatautf-8 image_urldata:;base64,highurldetailr;rBZfunctionResponsefunction_responsenameresponse)rKrL)r;rJ function_call functionCallNidargsrOrK argumentsr;rMcss|] }|ddkVqdS)r;r9Ngetrprrrr6s  cSr1r2rrrrrrr )rUr&r3r!listallrappendbytesbase64 b64encodedecodeto_dictjoin)r)r*r0r.r-r8Z text_parts content_partspartr<r=r?data_b64rJrMZmessage_contentrrr_process_gemini_inputs*s                   rfcCstt|}|di}t|dr|j}t|dd}t|dd}n|d}|d}|d}dd|d|||d S) z*Extract invocation parameters for tracing.r% temperatureZmax_output_tokensNZstop_sequencesgoogleZchatr/)Z ls_providerZ ls_model_typeZ ls_model_nameZls_temperatureZ ls_max_tokensZls_stop)r"rUhasattrrggetattr)r#strippedr%rgZ max_tokensstoprrr_infer_invocation_paramss       rmgemini_usage_metadatarc Cs|dpd}|dp d}|dpd}|dpd}|dp$||}i}|r-||d<i}|r5||d<t|||tdid d |Dtdid d |Dd S)z2Convert Gemini usage metadata to LangSmith format.prompt_token_countrcandidates_token_countcached_content_token_countthoughts_token_counttotal_token_countZ cache_readZ reasoningcSrrrrrrrrr z*_create_usage_metadata..cSrrrrrrrrr ) input_tokens output_tokens total_tokensinput_token_detailsoutput_token_detailsNr)rUrrr!r)rnrorprqrrrsrwrxrrr_create_usage_metadatas2  ryrLrc Cszt|dr |}nt|dr|}n dt|dt|i}d}g}d}d|vr|dr|dd}d|vr|d}d |vr|d r|d D]}d|vrc|drc||d7}|d|dd qHd |vr|d dur|d }|d d } |dd} t| trt |  d} n| } |dd| d| dddqHd|vsd|vr|dp|d} | durt| t s| } |d| d| d| diddqHd|vr|dr|d}nd|vr|d}|d|d dd |D} | r |pdd!|d"d t | Dd#}n t|d$ks |r'|dd%dkr'|d!|d&}n|d!|d&}|d'}tdddd(}|ryt|}t}|ryz|jd)id'i}|||Wntyx}ztd*|WYd}~nd}~ww|d+r|dd!||d+|d,WSt|dtr|dd!||d-WS|dd!||d-WSty}ztd.|d/|iWYd}~Sd}~ww)0z$Process Gemini response for tracing.ra model_dumpr9rYN candidatesrr.r8r:r<r=r>r?r@rArBrCrDrErFrIrMrNrOrKrPrQrS finish_reasoncSsg|] }|ddkr|qSrSrTrVrrrr72r z6_process_generate_content_response..Z assistantc SsNg|]#\}}|ddpd|d||ddt|ddddqS)rMrOZcall_functionrKrR)rKrR)rOr;indexr})rUjsondumps)riZtcrrrr79s  )r.r-r| tool_callsr;)r.r-r|usage_metadatartrurvmetadata!Failed to update usage metadata: r)r.r-r|rr)r.r-r|rz"Error processing Gemini response: output)rirarzrjr3r\rUr&r]r^r_r`r enumeratelenrryr get_current_run_treeextra setdefaultupdatepatch Exceptionloggerwarningdebug)rLZrdictZcontent_resultrcr| candidater.rdr<r=r?rerMrresultr usage_dict current_runmetaerrr"_process_generate_content_responses                     r all_chunksrZc Cs|s dtdddddSd}d}|D]-}zt|dr"|jr"||j7}|}Wqty?}ztd|WYd}~qd}~wwtdddd}|rz~t|dr|jrt|jd r^|j}n-t|jd rj|j}n!t |jd dt |jd dt |jd dt |jddt |jddd}t |}t }|rz|j didi}|||Wnty}ztd|WYd}~nd}~wwWnty}ztd|WYd}~nd}~ww||dS)z/Reduce streaming chunks into a single response.rYrr)r.rNr9zError processing chunk: rrarzrorprqrrrs)rorprqrrrsrrz+Error extracting metadata from last chunk: )rrir9rrrrrarzrjryr rrrrrr) r full_text last_chunkchunkrrrrrrrr_reduce_generate_content_chunkss       rForiginal_generaterrKr3 tracing_extraOptional[TracingExtra] is_streamingboolcsR|pitfdd}tfdd}tr'|S|S)z7Create a wrapper for Gemini's generate_content methods.c sHt|tjddr tndtstndtd}||i|SNZllm)rKZrun_typeZ reduce_fnZprocess_inputsZprocess_outputsZ_invocation_params_fnrr(r Z traceablerrfrrmrPr# decoratorrrKrZtextrarrgenerates    z_get_wrapper..generatec sPt|tjddrtndtstndtd}||i|IdHSrrrrrr agenerates    z_get_wrapper..agenerate) functoolswrapsr is_async)rrKrrrrrrr _get_wrappers rc@s&eZdZUded<ded<ded<dS) TracingExtrazOptional[Mapping[str, Any]]rzOptional[list[str]]tagszOptional[ls_client.Client]r N)__name__ __module__ __qualname____annotations__rrrrrs  r)totalZChatGoogleGenerativeAI)r chat_namer rcCs|pi}t|drt|jdrt|jjdrtdt|dr1t|jdr1t|jj||dd|j_t|drHt|jdrHt|jj||dd|j_t|d rht|jdrht|jjdrht|jjj||dd|jj_t|d rt|jdrt|jjdrt|jjj||dd|jj_|S) a Patch the Google Gen AI client to make it traceable. .. warning:: **BETA**: This wrapper is in beta. Supports: - generate_content() and generate_content_stream() methods - Sync and async clients - Streaming and non-streaming responses - Tool/function calling with proper UI rendering - Multimodal inputs (text + images) - Image generation with inline_data support - Token usage tracking including reasoning tokens Args: client (genai.Client): The Google Gen AI client to patch. tracing_extra (Optional[TracingExtra], optional): Extra tracing information. Defaults to None. chat_name (str, optional): The run name for the chat endpoint. Defaults to "ChatGoogleGenerativeAI". Returns: genai.Client: The patched client. Examples: .. code-block:: python from google import genai from google.genai import types from langsmith import wrappers # Use Google Gen AI client same as you normally would. client = wrappers.wrap_gemini(genai.Client(api_key="your-api-key")) # Basic text generation: response = client.models.generate_content( model="gemini-2.5-flash", contents="Why is the sky blue?", ) print(response.text) # Streaming: for chunk in client.models.generate_content_stream( model="gemini-2.5-flash", contents="Tell me a story", ): print(chunk.text, end="") # Tool/Function calling: schedule_meeting_function = { "name": "schedule_meeting", "description": "Schedules a meeting with specified attendees.", "parameters": { "type": "object", "properties": { "attendees": {"type": "array", "items": {"type": "string"}}, "date": {"type": "string"}, "time": {"type": "string"}, "topic": {"type": "string"}, }, "required": ["attendees", "date", "time", "topic"], }, } tools = types.Tool(function_declarations=[schedule_meeting_function]) config = types.GenerateContentConfig(tools=[tools]) response = client.models.generate_content( model="gemini-2.5-flash", contents="Schedule a meeting with Bob and Alice tomorrow at 2 PM.", config=config, ) # Image generation: response = client.models.generate_content( model="gemini-2.5-flash-image", contents=["Create a picture of a futuristic city"], ) # Save generated image from io import BytesIO from PIL import Image for part in response.candidates[0].content.parts: if part.inline_data is not None: image = Image.open(BytesIO(part.inline_data.data)) image.save("generated_image.png") .. versionadded:: 0.4.33 Initial beta release of Google Gemini wrapper. modelsgenerate_content __wrapped__zfThis Google Gen AI client has already been wrapped. Wrapping a client multiple times is not supported.F)rrgenerate_content_streamTaio)rirr ValueErrorrrr)r rrrrr wrap_gemini sbd           r)rrrr)r#rrr$)r)rrr)r#rrr)rnrrr)rLrrr)rrZrr)NF) rrrKr3rrrrrr)r rrrrr3rr)+ __future__rr^rrloggingcollections.abcrtypingrrrrrr Ztyping_extensionsr Z langsmithr Z ls_clientr Z#langsmith._internal._beta_decoratorr Zlangsmith.schemasrrrrhrr getLoggerrrr"r(rfrmryrrrrrrrrrsB              " #L 2