관리-도구
편집 파일: cohere.cpython-38.pyc
U �Mg2$ � @ s� d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dl m Z e rld dl m Z m Z mZ d dlmZ d d lZd d lmZ d d lmZmZ d d lmZmZ z<d d lmZ d dlm Z d dl m Z m Z e r�d dl m Z W n e!k r� ed��Y nX zd dl m"Z" W n" e!k �r, d dl m#Z" Y nX ej$ej%ej&ej'ej(ej)ej*d�Z+ej,ej-d�Z.dddd�Z/ddd d d d �Z0G d d!� d!e�Z1d"d#� Z2d$d%� Z3d&d'� Z4d S )(� ��wraps)�consts)�record_token_usage)�SPANDATA)�set_data_normalized)� TYPE_CHECKING)�Any�Callable�Iterator)�SpanN)�should_send_default_pii)� DidNotEnable� Integration)�capture_internal_exceptions�event_from_exception)�Client)� BaseCohere)�ChatStreamEndEvent�NonStreamedChatResponse)�StreamedChatResponsezCohere not installed)� StreamEndStreamedChatResponse)� StreamedChatResponse_StreamEnd)�model�k�p�seedZfrequency_penaltyZpresence_penaltyZ raw_prompting)Ztools�preamblezai.generation_idzai.is_search_requiredzai.finish_reason)Z generation_idZis_search_requiredZ finish_reasonz ai.citationsz ai.documentszai.search_querieszai.search_resultsz ai.tool_calls)Z citationsZ documentsZsearch_queriesZsearch_resultsZ tool_callsc @ s0 e Zd ZdZde� �Zd dd�Zedd� �ZdS ) �CohereIntegration�coherezauto.ai.Tc C s || _ d S )N)�include_prompts)�selfr � r" �L/opt/hc_python/lib/python3.8/site-packages/sentry_sdk/integrations/cohere.py�__init__I s zCohereIntegration.__init__c C s0 t tjdd�t_ttj�t_t tjdd�t_d S )NF)� streamingT)� _wrap_chatr Zchat� _wrap_embedr ZembedZ chat_streamr" r" r" r# � setup_onceM s z CohereIntegration.setup_onceN)T)�__name__� __module__� __qualname__� identifier�originr$ � staticmethodr( r" r" r" r# r E s r c C s0 t | t�� jddd�d�\}}tj||d� d S )Nr F)�typeZhandled)Zclient_optionsZ mechanism)�hint)r � sentry_sdk� get_client�optionsZ capture_event)�exc�eventr0 r" r" r# �_capture_exceptionU s � r6 c s$ dd� � t ��� ��fdd��}|S )Nc S s� |rJt |d�r t| tj|jg� tD ]$}t ||�r$t| d| t||�� q$tD ]$}t ||�rNt| d| t||�� qNt |d�r�t |jd�r�t | |jj j |jj j d� n&t |jd�r�t | |jj j |jj j d� t |jd�r�t| d|jj� d S ) N�textzai.�meta� billed_units)� prompt_tokensZcompletion_tokens�tokens�warningsz ai.warnings)�hasattrr r Z AI_RESPONSESr7 � COLLECTED_PII_CHAT_RESP_ATTRS�getattr�COLLECTED_CHAT_RESP_ATTRSr8 r r9 � input_tokensZ output_tokensr; r< )�span�res� include_piiZpii_attr�attrr" r" r# � collect_chat_response_fieldsb s8 � � � z0_wrap_chat.<locals>.collect_chat_response_fieldsc s� t �� �t�� � d ks.d|ks.t|�d�t�s8�| |�S |�d�}t jtj j dtj d���� � z�| |�}W n> t k r� } z t|� ��d d d � |d �W 5 d }~X Y nX t� ��8 t� �r&� j�r&t�tjttdd� |�dg ���d|d�g � t�� D ]$\}}||k�r t�||| � �q t�� D ]$\}}||k�r.t�||| � �q.t�tjd � ��r�|��� ��fd d �}|� W 5 Q R � S t|t ��rĈ�|t� �o�� jd � ��d d d � nt�d d� ��d d d � |W 5 Q R � S Q R X d S )N�messagezcohere.client.Chat��op�namer- c S s t | dd��� t | dd�d�S )N�role� rG �rK �content)r? �lower��xr" r" r# �<lambda>� s �z._wrap_chat.<locals>.new_chat.<locals>.<lambda>Z chat_history�userrM Fc 3 s` t � �B �D ]6} t| t�s$t| t�r<� �| jt� o6�jd� | V q W 5 Q R X ��d d d � d S )N�rD )r � isinstancer r �responser r �__exit__rP )rF � integration� old_iteratorrB r" r# � new_iterator� s ��z2_wrap_chat.<locals>.new_chat.<locals>.new_iteratorrT Zunknown_responseT) r1 r2 �get_integrationr rU �get�str� start_spanr �OPZ COHERE_CHAT_COMPLETIONS_CREATEr- � __enter__� Exceptionr6 rW r r r r r �AI_INPUT_MESSAGES�list�map�COLLECTED_PII_CHAT_PARAMS�items�COLLECTED_CHAT_PARAMSZ AI_STREAMINGr )�args�kwargsrG rC �er �vrZ �rF �fr% )rX rY rB r# �new_chat� sr ��� � �� �� � z _wrap_chat.<locals>.new_chatr )rm r% rn r" rl r# r& _ s "Vr& c s t � �� fdd��}|S )Nc sl t �� �t�}|d kr � | |�S t jtjjdtjd���*}d|kr�t � r�|j r�t |d t �rpt |d|d g� nBt |d t�r�t|d �dkr�t |d d t �r�t |tj|d � d|kr�t |tj|d � z� | |�}W n2 tk �r } zt|� |d �W 5 d }~X Y nX t|d��rRt|jd��rRt|jjd ��rRt||jjj|jjjd � |W 5 Q R � S Q R X d S ) NzCohere Embedding CreationrH Ztextszai.textsr r r8 r9 rA )r: Z total_tokens)r1 r2 r[ r r^ r r_ ZCOHERE_EMBEDDINGS_CREATEr- r r rU r] r rc �lenr rb � AI_MODEL_IDra r6 r= r8 r9 r rA )rh ri rX rB rC rj �rm r" r# � new_embed� s\ ��� ��� �� � ��z _wrap_embed.<locals>.new_embedr )rm rr r" rq r# r' � s ,r' )5� functoolsr r1 r Zsentry_sdk.ai.monitoringr Zsentry_sdk.constsr Zsentry_sdk.ai.utilsr �typingr r r r Zsentry_sdk.tracingr Zsentry_sdk.scoper Zsentry_sdk.integrationsr r Zsentry_sdk.utilsr r Z cohere.clientr Zcohere.base_clientr r r r r � ImportErrorr r rp ZAI_TOP_KZAI_TOP_PZAI_SEEDZAI_FREQUENCY_PENALTYZAI_PRESENCE_PENALTYZAI_RAW_PROMPTINGrg ZAI_TOOLSZ AI_PREAMBLEre r@ r> r r6 r& r' r" r" r" r# �<module> sb � ���