Ig(bddlZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZej&ej(dej*eZeej2Zde e ee ee effd dfd ZGd d Zdd ZddZedk(reyy)N)Path)DictListMappingOptionalUnioncastenv)utilsz %(message)s)levelformatservices_statusreturnc g}|D]}t|dt|dd}ttt|j dg}|r.dj |Dcgc]}t|dc}|d<|j |td|D}td |D}d dj|d zzdj|d zzd zg}|D]Y}|dj|d z} |dj|d z} |j dd } |j | | z| z[|j dtjd j |ycc}w)NServiceStatus)rr Publishersz, PublishedPortPublishedPortsc38K|]}t|dyw)rNlen.0services O/var/www/html/answerous/venv/lib/python3.12/site-packages/langsmith/cli/main.py z"pprint_services.."sJg#gi01Jc38K|]}t|dyw)rNrrs rrz"pprint_services..#sG7GH-.Gr zPublished Portsz To connect, set the following environment variables in your LangChain application: LANGSMITH_TRACING_V2=true LANGSMITH_ENDPOINT=http://localhost:80/api) strr rrgetjoinappendmaxljustloggerinfo) rservicesrservice_status publishers publishermax_service_len max_state_lenservice_message service_str state_str ports_strs rpprint_servicesr6sH" (79-.'(+,* $t*gkk,&CD /3yyBLMYY/0M0N+ , ' (JJJOGhGGM ///A- . / ..* + ,  O Di(../BC H%++MA,=> KK 0"5 {Y6BC D  7  KK /*+1NsE7 c eZdZdZddZedeefdZdeddfdZ ddZ d d d eddfd Z dd d de eded eddfdZ ddeddfdZddZddZy)LangSmithCommandz$Manage the LangSmith Tracing server.rNcbttjjdz |_y)Nzdocker-compose.yaml)r__file__absoluteparentdocker_compose_fileselfs r__init__zLangSmithCommand.__init__<s& N # # % , ,/D D  c*tjSN)ls_utilsget_docker_compose_commandr>s rdocker_compose_commandz'LangSmithCommand.docker_compose_commandAs2244rAurlcR tjd|gy#t$rYywxYw)Nopen) subprocessrunFileNotFoundError)r?rGs r _open_browserzLangSmithCommand._open_browserEs)  NNFC= )    s  &&c(g|jdt|j}tjg|dddt j dt j dt j d|jdy) 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)rFr$r=rJrKr*r+rM)r?commands r _start_localzLangSmithCommand._start_localKs  ( (   (( )            :   ./ DE -.rA0.5.7versionrUc|tjd<tjg|jdt |j dy)zPull the latest LangSmith images. Args: version: The LangSmith version to use for LangSmith. Defaults to 0.5.7 _LANGSMITH_IMAGE_VERSIONrOpullN)osenvironrJrKrFr$r=)r?rUs rrXzLangSmithCommand.pullesY29 -. ,,  D,,-    rA)openai_api_keyrUr[langsmith_license_keyc||tjd<||tjd<|j||jy)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_KEYrT)rYrZrXrR)r?r[r\rUs rstartzLangSmithCommand.startysH(  %+9BJJ' ( ,2GBJJ. / ' " rA clear_volumescg|jdt|jd}|r;td}|j dk7r t dy|j dtj|y)Stop the LangSmith server.rOdownzYou 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) rFr$r=inputlowerprintr'rJrK)r?racmdconfirms rstopzLangSmithCommand.stops  ( (   (( )     GG }}#%k" JJ{ #srAcxtjg|jdt|jdy)z)Print the logs from the LangSmith server.rOlogsN)rJrKrFr$r=r>s rrmzLangSmithCommand.logssH ,,  D,,-    rAcg|jdt|jddd}tj|tj tj } |j jd}tj|}|r!tjd t|ytjd y#tj$rtjdYywxYw) z6Provide information about the status LangSmith server.rOpsz--formatjson)stdoutstderrzutf-8z'Error checking LangSmith server status.Nz*The LangSmith server is currently running.z$The LangSmith server is not running.)rFr$r=rJrKPIPErqdecoderploadsJSONDecodeErrorr*errorr+r6)r?rQresultcommand_stdoutrs rstatuszLangSmithCommand.statuss  ( (   (( )         ????   #]]11':N"jj8O  KKD E O , KK> ? ##  LLB C  s!0C (C54C5rN)F)__name__ __module__ __qualname____doc__r@propertyrr$rFrMrRrXrr`boolrkrmrzrArr8r89s. 5S 55 /:     .)- !  #     6$4*  rAr8ctj}|jtj|jtjt d|j D}tjd|jD]#\}}tj||dd|%y)z*Print the runtime environment information.c32K|]}t|ywrCr)rkeys rrzenv..s8cS8szLangChain Environment:r#z: N) ls_envget_runtime_environmentupdateget_docker_environmentget_langchain_env_varsr(keysr*r+items)r max_key_lengthkvs rr r s  ( ( *CJJv,,./JJv,,./8SXXZ88N KK() 21 q.))*"QC012rAc tdtdtj}|jd}t |j dd}|j dtjdd |j d tjd d |j ddd |j fd|j dd}|j ddd|j fd|j dd}|j ddd |j fd|j dd}|j fd|j d d!}|j fd"|j d#}|jd$|j}t|d%s|jy&|j|y&)'zMain entrypoint for the CLI.zThe LangSmith version to use for LangSmith. Defaults to 0.5.7.chj|j|j|jS)N)r[r\rU)r`r[r\rUargsserver_commands rzmain..s0....."&"<"<LL/ rA)funcrkrcz--clear-volumes store_truez?Delete all the locally cached LangSmith containers and volumes.)actionrc<j|jS)N)ra)rkrars rrzmain..s.--D.s.--dll-CrArmzShow the LangSmith server logs.c$jSrC)rmrs rrzmain..#sn6I6I6KrArzz!Show the LangSmith server status.c$jSrC)rzrs rrzmain..'s8M8M8OrAr ctSrCr )rs rrzmain..)scerArN)rhargparseArgumentParseradd_subparsersr8 add_parser add_argumentrYgetenv set_defaults parse_argshasattr print_helpr) parser subparsersserver_start_parserserver_stop_parserserver_pull_parserserver_logs_parserserver_status_parser env_parserrrs @rmainrsE HI <=  $ $ &F&&3K&LJ%'N$//:0$$ *+=%$$! 127%$$ M% $$ %$..8/## N$ ## O$$..?/## M$ ## C$$..=/##)K#L%00A1%%+O%P&&u-J!34    D 4 IIdOrA__main__r{)rrploggingrYrJpathlibrtypingrrrrrr langsmithr rr rD basicConfigINFO getLoggerr|r*r:r<_DIRr$r6r8rrrArrs  ==#'',,}=   8 $ H~$,T'#uS$s)^7L2L*M%N$,SW$,NVVr 2Od zFrA