ܘh.zddlZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZddlmZejejdejeZeejZde e ee ee effd dfd ZGd d Zdd ZddZedkr edSdS)N)Path)DictListLiteralMappingOptionalUnioncastenv)utilsz %(message)s)levelformatservices_statusreturncg}|D]}t|dt|dd}ttt|dg}|r"dd|D|d<||td|D}td |D}d d|d zzd|d zzd zg}|D]o}|d|d z}|d|d z} |dd } ||| z| zp|dt d |dS)NServiceStatus)rr Publishersz, c8g|]}t|dS) PublishedPort)str).0 publishers Z/var/www/html/services/rag-service/venv/lib/python3.11/site-packages/langsmith/cli/main.py z#pprint_services..s%MMMYY/00MMMPublishedPortsc3@K|]}t|dVdS)rNlenrservices r z"pprint_services.."s/JJg#gi011JJJJJJrc3@K|]}t|dVdS)rNr r"s rr$z"pprint_services..#s/GG7GH-..GGGGGGr zPublished Portsz To connect, set the following environment variables in your LangChain application: LANGCHAIN_TRACING_V2=true LANGCHAIN_ENDPOINT=http://localhost:80/api) rr rrgetjoinappendmaxljustloggerinfo) rservicesr#service_status publishersmax_service_len max_state_lenservice_message service_str state_str ports_strs rpprint_servicesr9sH" ( (79-..'(+,,* * $t*gkk,&C&CDD  /3yyMM*MMM00N+ , ''''JJJJJJJOGGhGGGGGM ///A- . . / ..* + + ,  O DDi(../BCC H%++MA,=>> KK 0"55 {Y6BCCCC 7  KK /**+++++rc 6eZdZdZddZedeefdZdeddfdZ ddZ d d d d e e d e d e dfdeddfdZ d dd dd e e d e d e dfdeedededdf dZddeddfdZddZddZdS)LangSmithCommandz$Manage the LangSmith Tracing server.rNclttjdz |_dS)Nzdocker-compose.yaml)r__file__absoluteparentdocker_compose_fileselfs r__init__zLangSmithCommand.__init__<s. NN # # % % ,/D D    rc(tjSN)ls_utilsget_docker_compose_commandrAs rdocker_compose_commandz'LangSmithCommand.docker_compose_commandAs2444rurlcV tjd|gdS#t$rYdSwxYw)Nopen) subprocessrunFileNotFoundError)rBrIs r _open_browserzLangSmithCommand._open_browserEsC  NFC= ) ) ) ) )     DD s  ((cBg|jdt|j}tjg|dddt dt dt d|ddS) N-fupz --quiet-pullz--waitaLangSmith server is running at http://localhost:80/api. To view the app, navigate your browser to http://localhost:80 To connect your LangChain application to the server locally, set the following environment variable when running your LangChain application. z LANGCHAIN_TRACING_V2=truez, LANGCHAIN_ENDPOINT=http://localhost:80/api zhttp://localhost)rHrr@rLrMr.r/rO)rBcommands r _start_localzLangSmithCommand._start_localKs  (   ( ) )              :     1222 DEEE -.....rprodlateststageversionrXdevbetarYc|dkrdtjd<n|dkrdtjd<|tjd<tjg|jdt |jdd S) zPull the latest LangSmith images. Args: stage: Which stage of LangSmith images to pull. One of "prod", "dev", or "beta". rZzdev-_LANGSMITH_IMAGE_PREFIXr[zrc-_LANGSMITH_IMAGE_VERSIONrQpullN)osenvironrLrMrHrr@)rBrXrYs rr_zLangSmithCommand.pulles E>>4:BJ0 1 1 f__49BJ0 118 -. ,  D,--        r)rXopenai_api_keyrYrblangsmith_license_keyc||tjd<||tjd<||||dS)aRun the LangSmith server locally. Args: expose: If True, expose the server to the internet using ngrok. auth_token: The ngrok authtoken to use (visible in the ngrok dashboard). If not provided, ngrok server session length will be restricted. stage: Which set of images to pull when running. One of "prod", "dev", or "beta". openai_api_key: The OpenAI API key to use for LangSmith If not provided, the OpenAI API Key will be read from the OPENAI_API_KEY environment variable. If neither are provided, some features of LangSmith will not be available. langsmith_license_key: The LangSmith license key to use for LangSmith If not provided, the LangSmith license key will be read from the LANGSMITH_LICENSE_KEY environment variable. If neither are provided, Langsmith will not start up. NOPENAI_API_KEYLANGSMITH_LICENSE_KEYrW)r`rar_rT)rBrXrbrcrYs rstartzLangSmithCommand.startsX2  %+9BJ' ( ,2GBJ. / w /// rF clear_volumescg|jdt|jd}|rMtd}|dkrt ddS|dtj|dS)Stop the LangSmith server.rQdownzYou are about to delete all the locally cached LangSmith containers and volumes. This operation cannot be undone. Are you sure? [y/N]yz Aborting.Nz --volumes) rHrr@inputlowerprintr+rLrM)rBrhcmdconfirms rstopzLangSmithCommand.stops  (   ( ) )      $GG }}#%%k""" JJ{ # # #srcltjg|jdt|jddS)z)Print the logs from the LangSmith server.rQlogsN)rLrMrHrr@rAs rrtzLangSmithCommand.logssW ,  D,--        rcg|jdt|jddd}tj|tjtj} |jd}tj |}n0#tj $rt dYdSwxYw|r+t d t|dSt d dS) z6Provide information about the status LangSmith server.rQpsz--formatjson)stdoutstderrzutf-8z'Error checking LangSmith server status.Nz*The LangSmith server is currently running.z$The LangSmith server is not running.)rHrr@rLrMPIPErxdecoderwloadsJSONDecodeErrorr.errorr/r9)rBrSresultcommand_stdoutrs rstatuszLangSmithCommand.statuss   (   ( ) )         ??     #]11'::N"j88OO#    LLB C C C FF    KKD E E E O , , , , , KK> ? ? ? Fs.B)B.-B.rN)F)__name__ __module__ __qualname____doc__rCpropertyrrrHrOrTr rr_rrgboolrrrtrrrr;r;9s..    5S 555X5 ////:JP    WV_gengfoEF        :JP(, WV_gengfoEF!  #    @$4*     rr;ctj}|tj|tjt d|D}td| D]&\}}t||d|'dS)z*Print the runtime environment information.c34K|]}t|VdSrEr )rkeys rr$zenv..s(88cS888888rzLangChain Environment:z: N) ls_envget_runtime_environmentupdateget_docker_environmentget_langchain_env_varsr,keysr.r/items)r max_key_lengthkvs rr r s  ( * *CJJv,..///JJv,..///88SXXZZ88888N KK())) 221 q.000Q00111122rc, tdtdtj}|d}t |dd}|ddgd d |d tjd d|dtjdd|ddd| fd|dd}|ddd| fd|dd }|ddgd d! |ddd| fd"|d#d$}| fd%|d&d'}| fd(|d)}| d*| }t|d+s| d,S| |d,S)-zMain entrypoint for the CLI.zzmain..s2...*."&"<L /  r)funcrrrjz--clear-volumes store_truez?Delete all the locally cached LangSmith containers and volumes.)actionrc:|jS)N)rh)rrrhrs rrzmain..(s.--D.=s.--DJ -UUrrtzShow the LangSmith server logs.c,SrE)rtrs rrzmain..Bsn6I6I6K6Krrz!Show the LangSmith server status.c,SrE)rrs rrzmain..Fs8M8M8O8Orr ctSrEr )rs rrzmain..Hs ceerrN)roargparseArgumentParseradd_subparsersr; add_parser add_argumentr`getenv set_defaults parse_argshasattr print_helpr) parser subparsersserver_start_parserserver_stop_parserserver_pull_parserserver_logs_parserserver_status_parser env_parserrrs @rmainrs HIII <===  $ & &F&&3K&LLJ%''N$//:0$$''' 8 % $$ *++=%$$! 1227%$$5%$$    %$..8/## N$ ## O O O O$$..?/##''' 7 $ ##5$## U U U U$$..=/##)K)K)K)K#LLL%00A1%%+O+O+O+O%PPP&&u--J!3!3444     D 4 IIdOOOOOr__main__r) rrwloggingr`rLpathlibrtypingrrrrrr r langsmithr rr rF basicConfigINFO getLoggerrr.r=r?_DIRrr9r;rrrrrs  FFFFFFFFFFFFFFFFFF######''''''',}====  8 $ $ tH~~$,T'#uS$s)^7L2L*M%N$,SW$,$,$,$,NbbbbbbbbJ 2 2 2 2bbbbJ zDFFFFFr