Ng(vddlZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZejejdejeZeejZde e ee ee effd dfd ZGd d Zdd ZddZedkr edSdS)N)Path)DictListMappingOptionalUnioncastenv)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 N/var/www/html/ai-engine/env/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)rNrr!s rr#z"pprint_services..#s/GG7GH-..GGGGGGr zPublished Portsz To connect, set the following environment variables in your LangChain application: LANGSMITH_TRACING_V2=true LANGSMITH_ENDPOINT=http://localhost:80/api) rr rrgetjoinappendmaxljustloggerinfo) rservicesr"service_status publishersmax_service_len max_state_lenservice_message service_str state_str ports_strs rpprint_servicesr8sH" ( (79-..'(+,,* * $t*gkk,&C&CDD  /3yyMM*MMM00N+ , ''''JJJJJJJOGGhGGGGGM ///A- . . / ..* + + ,  O DDi(../BCC H%++MA,=>> KK 0"55 {Y6BCCCC 7  KK /**+++++rc eZdZdZddZedeefdZdeddfdZ ddZ d d d eddfd Z dd d de eded eddfdZ ddeddfdZddZddZdS)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_commandr@s rdocker_compose_commandz'LangSmithCommand.docker_compose_commandAs2444rurlcV tjd|gdS#t$rYdSwxYw)Nopen) subprocessrunFileNotFoundError)rArHs 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 LANGSMITH_TRACING=truez, LANGSMITH_ENDPOINT=http://localhost:80/api zhttp://localhost)rGrr?rKrLr-r.rN)rAcommands r _start_localzLangSmithCommand._start_localKs  (   ( ) )              :     ./// DEEE -.....r0.5.7versionrVc|tjd<tjg|jdt |jddS)zPull the latest LangSmith images. Args: version: The LangSmith version to use for LangSmith. Defaults to 0.5.7 _LANGSMITH_IMAGE_VERSIONrPpullN)osenvironrKrLrGrr?)rArVs rrYzLangSmithCommand.pullesf29 -. ,  D,--        r)openai_api_keyrVr\langsmith_license_keyc||tjd<||tjd<|||dS)aRun the LangSmith server locally. Args: 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. version: The LangSmith version to use for LangSmith. Defaults to latest. NOPENAI_API_KEYLANGSMITH_LICENSE_KEYrU)rZr[rYrS)rAr\r]rVs rstartzLangSmithCommand.startysV(  %+9BJ' ( ,2GBJ. / ' """ rF clear_volumescg|jdt|jd}|rMtd}|dkrt ddS|dtj|dS)Stop the LangSmith server.rPdownzYou 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) rGrr?inputlowerprintr*rKrL)rArbcmdconfirms rstopzLangSmithCommand.stops  (   ( ) )      $GG }}#%%k""" JJ{ # # #srcltjg|jdt|jddS)z)Print the logs from the LangSmith server.rPlogsN)rKrLrGrr?r@s rrnzLangSmithCommand.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.rPpsz--formatjson)stdoutstderrzutf-8z'Error checking LangSmith server status.Nz*The LangSmith server is currently running.z$The LangSmith server is not running.)rGrr?rKrLPIPErrdecoderqloadsJSONDecodeErrorr-errorr.r8)rArRresultcommand_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__rBpropertyrrrGrNrSrYrraboolrlrnr{rrr:r:9sg..    5S 555X5 ////:          .)- !  #     6$4*     rr:ctj}|tj|tjt d|D}td| D]&\}}t||d|'dS)z*Print the runtime environment information.c34K|]}t|VdSrDr)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}|dtjdd |d tjd d |ddd | fd|dd}|ddd| fd|dd}|ddd | fd|dd}| fd|d d!}| fd"|d#}| d$| }t|d%s| d&S| |d&S)'zMain entrypoint for the CLI.zThe LangSmith version to use for LangSmith. Defaults to 0.5.7.cR|j|j|jS)N)r\r]rV)rar\r]rVargsserver_commands rzmain..s-...."&"<L/  r)funcrlrdz--clear-volumes store_truez?Delete all the locally cached LangSmith containers and volumes.)actionrc:|jS)N)rb)rlrbrs rrzmain..s.--D.s.--dl-CCrrnzShow the LangSmith server logs.c,SrD)rnrs rrzmain..#sn6I6I6K6Krr{z!Show the LangSmith server status.c,SrD)r{rs rrzmain..'s8M8M8O8Orr ctSrDr )rs rrzmain..)s ceerrN)riargparseArgumentParseradd_subparsersr: add_parser add_argumentrZgetenv 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$$ *++=%$$! 1227%$$ M% $$    %$..8/## N$ ## O O O O$$..?/## M$ ## C C C C$$..=/##)K)K)K)K#LLL%00A1%%+O+O+O+O%PPP&&u--J!3!3444     D 4 IIdOOOOOr__main__r|)rrqloggingrZrKpathlibrtypingrrrrrr langsmithr rr rE basicConfigINFO getLoggerr}r-r<r>_DIRrr8r:rrrrrs  ================######''''''',}====  8 $ $ tH~~$,T'#uS$s)^7L2L*M%N$,SW$,$,$,$,NVVVVVVVVr 2 2 2 2OOOOd zDFFFFFr