;3hbdZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlmZddlmZddlmZddlmZddlmZdd lmZdd l mZdd lmZm Z ddl!Z!ddl"Z"dd l"m#Z#m$Z$m%Z%dd l&m'Z'm(Z(m)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5m6Z6ddl7m8Z8m9Z9m:Z:m;Z;mZ>ej~jdxs eAee jdz ZCe3dddddGddZDeGddZEeGd d!ZFGd"d#ZGe3d$d%d&Gd'd(eZHy))z,The main Client class for the Python client.) annotationsN)Callable)Future) dataclass)datetime)partial)Path)Lock)AnyLiteral)CommitOperationAdd SpaceHardware SpaceStage)RepositoryNotFoundErrorbuild_hf_headerssend_telemetry)version)utils)EndpointV3Compatibility) ParameterInfo)document)AppErrorAuthenticationError) Communicator JobStatusMessage QueueError ServerMessageStatus StatusUpdateGRADIO_TEMP_DIRgradiopredictsubmitview_api duplicatedeploy_discordceZdZdZ ddedddd d dZdZdZ d!dZd Z e d" d#d Z d Z ddd  d$d Z d%dZdddd d&dZdZ d' d(dZd)dZd*dZ d+dZdZdZd)dZd,dZdZd-dZd.dZd/dZ d0 d1dZy)2Clienta The main Client class for the Python client. This class is used to connect to a remote Gradio app and call its API endpoints. Example: from gradio_client import Client client = Client("abidlabs/whisper-large-v2") # connecting to a Hugging Face Space client.predict("test.mp4", api_name="/predict") >> What a nice recording! # returns the result of the remote API call client = Client("https://bec81a83-5b5c-471e.gradio.live") # connecting to a temporary Gradio share URL job = client.submit("hello", api_name="/predict") # runs the prediction in a background thread job.result() >> 49 # returns the result of the remote API call (blocking call) TN)headersdownload_files ssl_verify_skip_componentsanalytics_enabledc ||_||_||_| |_t |dt j |_|r|jj|| |_ d|_ i|_ t|jttfrtj j#|js!tj$|jdtj j'|jst)d|jdt|j|_n t,|_|j/ds|j/d r|j1d r|n|d z} n)|j3|} | t)d |d ||_ | |_|j7} | t8j:k(rp|jr t=d |j7t8j:k(r8t?j@d |j7t8j:k(r8| t jBvrt)d| d|jrt=d|j4d|in||_"||jG||jI|_%|jJjMdd|_'|jJjMdd}|jQd d z|_)tTjVjY|j4|jRj[d d z|_.tTjVjY|j\t j^|_0tTjVjY|j\|jNdk(rt jbnt jd|_3tTjVjY|j\t jh|_5tTjVjY|j\|jNdk(rt jlnt jn|_8tTjVjY|j\jsdddt jt|_;tTjVjY|j\t jx|_=tTjVjY|j\t j||_?tjV|jJjMdd|_A|j|_Cttj|_F|jNj/drtnt}t|jJdDcic];\}}|jMd||||jMd|||jN=c}}|_Jtjj||_N| xstjdd d k(|_P|jr/tj|jd!jtj|_Vtj|_Wtj|jd!|_Y|jjd"|_Zd|_[i|_\t|_^ycc}}w)#a Parameters: src: either the name of the Hugging Face Space to load, (e.g. "abidlabs/whisper-large-v2") or the full URL (including "http" or "https") of the hosted Gradio app to load (e.g. "http://mydomain.com/app" or "https://bec81a83-5b5c-471e.gradio.live/"). hf_token: optional Hugging Face token to use to access private Spaces. By default, no token is sent to the server. Set `hf_token=None` to use the locally saved token if there is one (warning: only provide a token if you are loading a trusted private Space as the token can be read by the Space you are loading). Find your tokens here: https://huggingface.co/settings/tokens. max_workers: maximum number of thread workers that can be used to make requests to the remote Gradio app simultaneously. verbose: whether the client should print statements to the console. headers: additional headers to send to the remote Gradio app on every request. By default only the HF authorization and user-agent headers are sent. This parameter will override the default headers if they have the same keys. download_files: directory where the client should download output files on the local machine from the remote API. By default, uses the value of the GRADIO_TEMP_DIR environment variable which, if not set by the user, is a temporary directory on your machine. If False, the client does not download files and returns a FileData dataclass object with the filepath on the remote machine instead. ssl_verify: if False, skips certificate validation which allows the client to connect to Gradio apps that are using self-signed certificates. httpx_kwargs: additional keyword arguments to pass to `httpx.Client`, `httpx.stream`, `httpx.get` and `httpx.post`. This can be used to set timeouts, proxies, http auth, etc. analytics_enabled: Whether to allow basic telemetry. If None, will use GRADIO_ANALYTICS_ENABLED environment variable or default to True. gradio_client)token library_namelibrary_versionNTexist_okzPath: z is not a directory.zhttp://zhttps:///Could not find Space: z7. If it is a private Space, please provide an hf_token.z'Space is still building. Please wait...z+The current space is in the invalid state: z'. Please contact the owner to fix this.zLoaded as API: u ✔protocolws api_prefixssehttprz2.0 dependenciesid) max_workersGRADIO_ANALYTICS_ENABLEDTrue)targetdaemonF)_verbosehf_tokenr+r-rr __version__r*updater,space_idcookies isinstancestrr ospathexistsmakedirsisdir ValueError output_dirDEFAULT_TEMP_DIR startswithendswith_space_name_to_srcsrc_get_space_staterBUILDINGprinttimesleepINVALID_RUNTIME httpx_kwargs_login _get_configconfiggetr9lstripr;urllibparseurljoinrstrip src_prefixedAPI_URLapi_url SSE_URL_V0SSE_URLsse_url HEARTBEAT_URL heartbeat_urlSSE_DATA_URL_V0 SSE_DATA_URL sse_data_urlreplaceWS_URLws_url UPLOAD_URL upload_url RESET_URL reset_urlr app_version _get_api_info_infouuiduuid4 session_hashEndpointr enumerate endpoints concurrentfuturesThreadPoolExecutorexecutorgetenvr. threadingThread_telemetry_threadstartEvent_refresh_heartbeat_kill_heartbeat_stream_heartbeat heartbeat stream_openstreaming_futurepending_messages_per_eventsetpending_event_ids)selfrZrHrBrGauthrar*r+r,r-r._srcstater;endpoint_classfn_index dependencys T/var/www/html/audio-gradio/venv/lib/python3.12/site-packages/gradio_client/client.py__init__zClient.__init__Ls6   , 0'(!--   LL   ($ ') d))C; 777>>$"5"56 D//$?77==!4!45 6$*=*=)>>R!STT!$"5"56DO.DO >>) $z(B,,s+3sD**3/D| ,SE1hi DM%%' J'' '||?@'')Z-@-@@ 1 '')Z-@-@@ E)) )=eWE88  << ODHH:T2 3"."6BL   KK &&( KKOOJ - ++//,; $++C036 LL 4?? ; B B3 G# M ||++D,=,=u}}M ||++    $  6E  EMM  $\\11   u22 #LL00   %)]]e%;E ! !ASAS ll**    % %fdA 6   !,,..t/@/@%BRBRS--d.?.?Q"==E)JK'')  - 007H=T )2$++n2M(N  %* NN4 *NjnnT84j$---  #**==+=V   X+Ev!NRX!X   ! !   D$:$:4 H N N P"+//"3(0"))1G1GPTU  /3KM'+.51 sA]#cp|jj|jjdy)Nr?timeout)rrrjoinrs rclosez Client.closes)   " A&cZ |jj|j} |jj }|j ddt jd|f|j|j|jd|5}|jD]\}|jjr|jjn&|jjsTdddyddd#1swY xYw#t j $rYywxYw)N)rrGETr*rLverify)rrformatrracopy setdefaulthttpxstreamr*rLr, iter_linesris_setclearrTransportError)rurlraresponse_s rrzClient._stream_heartbeats$$++9J9J+KC #00557 '' 26\\!LL LL??  #  #%002#2299; 3399;!//668" # ## #  # #''  s=A%DA$D3D4D=D>DD DD*)D*c |jj}|jdtjdtj dd|j i|5}|jd|jd|ji|j|j5}d}|jD]}||z }d|vs|jdd \}}|jd jd }t!|sF|j#d rjt%j&|d d}|dt(j*k(r|j-ddt(j.k(rB|j0j3D]} | j5|ddddddy|dt(j6k(rd|_ddddddy|d} | |j0vrg|j0| <|j0| j5||dt(j:k(r|j<j?| t!|j<dk(r-|dk7r(d|_ddddddytAd|dd|vrҐ ddddddy#1swYxYw#1swYyxYw#tB$r:} tE| tjFrYd} ~ yddl$} | jK| d} ~ wwxYw)Nrrrrr)paramsr*rLrs r?utf-8 zdata:msgmessager<Fevent_idrsse_v3zUnexpected SSE line: '')&rarrrTimeoutr)r,rrprr*rL iter_bytessplitdecoderjlenrWjsonloadsrrreserver_stoppedrvaluesappend close_streamrprocess_completedrremoverT BaseExceptionrMRemoteProtocolError traceback print_exc) rr9raclientrbufferchunklineresppending_messagesrers rstream_messageszClient.stream_messagess= ,,113L  # #Iu}}T/J K0 S]]LL*D,=,=> LL LL #,S  F!)!4!4!6$S%%/+1<<+CLD&#';;w#7#>#>t#DD#&t9 (#w7'+zz$qr(';#';-2I2I#I$,$(HHY$;'4'C'C%D *.)H)H)O)O)Q%F(8(8(?(?(E%F%+7,S 0 S0 S@&*%[M4N4N%N7(>$?1$D(0H(<7.open_streamFs++H55rczd_jjD]\}}|jdy)NF)rritemsr)rrrs rrz&Client.send_data..close_streamIs=#( +/+J+J+P+P+R2'A'$++D12r)add_zero_gpu_headersr*rpostrurLr,ra status_coderraise_for_statusrrrdonerr$add_done_callback) rdata hash_datar9r*reqrrrrs ` ` r send_datazClient.send_data3s++DLL9jj    &D&I&LL??     ??c !?@ @ xxz ##D  6 2 $$,0E0E0J0J0L(, (<(<[(I%%%77 Erc  tj||} |r0d|vr|j dd}tj ||} n)tj |j dd|} tj| || r,t dtjj| d|tjd tj| |}|jxstj j"}|xs | j}||k7r'tj$| ||t d|d|tj j"k7rtj&| ||dz| r t d|| ||| }|S#t$r} td|d| d} ~ wwxYw#t$r| rt d |d tj|| |d | |2|jD]\} }tj| | || | r+t dtjj| YwxYw)ak Duplicates a Hugging Face Space under your account and returns a Client object for the new Space. No duplication is created if the Space already exists in your account (to override this, provide a new name for the new Space using `to_id`). To use this method, you must provide an `hf_token` or be logged in via the Hugging Face Hub CLI. The new Space will be private by default and use the same hardware as the original Space. This can be changed by using the `private` and `hardware` parameters. For hardware upgrades (beyond the basic CPU tier), you may be required to provide billing information on Hugging Face: https://huggingface.co/settings/billing Parameters: from_id: The name of the Hugging Face Space to duplicate in the format "{username}/{space_id}", e.g. "gradio/whisper". to_id: The name of the new Hugging Face Space to create, e.g. "abidlabs/whisper-duplicate". If not provided, the new Space will be named "{your_HF_username}/{space_id}". hf_token: optional Hugging Face token to use to duplicating private Spaces. By default, no token is sent to the server. Set `hf_token=None` to use the locally saved token if there is one. Find your tokens here: https://huggingface.co/settings/tokens. private: Whether the new Space should be private (True) or public (False). Defaults to True. hardware: The hardware tier to use for the new Space. Defaults to the same hardware tier as the original Space. Options include "cpu-basic", "cpu-upgrade", "t4-small", "t4-medium", "a10g-small", "a10g-large", "a100-large", subject to availability. secrets: A dictionary of (secret key, secret value) to pass to the new Space. Defaults to None. Secrets are only used when the Space is duplicated for the first time, and are not updated if the duplicated Space already exists. sleep_timeout: The number of minutes after which the duplicate Space will be puased if no requests are made to it (to minimize billing charges). Defaults to 5 minutes. max_workers: The maximum number of thread workers that can be used to make requests to the remote Gradio app simultaneously. verbose: Whether the client should print statements to the console. Example: import os from gradio_client import Client HF_TOKEN = os.environ.get("HF_TOKEN") client = Client.duplicate("abidlabs/whisper", hf_token=HF_TOKEN) client.predict("audio_sample.wav") >> "This is a test of the whisper speech recognition model." r1r7z9. If it is a private Space, please provide an `hf_token`.Nr6r?zUsing your existing Space: u 🤗zSecrets are only used when the Space is duplicated for the first time, and are not updated if the duplicated Space already exists.zCreating a duplicate of u for your own use... 🤗T)from_idto_idr1r5privatezCreated new Space: z1------- NOTE: this Space uses upgraded hardware: zG... see billing info at https://huggingface.co/settings/billing -------<)rHtimeout_in_secondsr<)rHrBrG)huggingface_hubget_space_runtimerrTrget_full_repo_namer]r SPACE_URLrwarningswarnduplicate_spaceradd_space_secrethardwarer CPU_BASICrequest_space_hardwareset_space_timeout)clsrrrHrrsecrets sleep_timeoutrBrG original_infornferKkeyvalue current_infocurrent_hardwarers rr&zClient.duplicateTsmj +==gXVM e| C(+&99%xPH&99 c"1%XH P  - -hh G1%//2H2H2R1SSXY" Y('88R  ! ! L_%B%B%L%L 5}55 x '  2 28XX V DXJOWX  44>> >  # #8 PR@R   "I x['  y' ( 1jk  ,' P0 9RST  + +  ""/'--/JC#44 #uH+EOO,B,B8,L+MNO! Ps+F5AG F=(F88F=BIIc|jsytj|j|j}|jSNr)rKrrrHstage)rinfos rr[zClient._get_space_states0}}00dmmTzzrapi_namercl|j|||j|||d|jS)a Calls the Gradio API and returns the result (this is a blocking call). Arguments can be provided as positional arguments or as keyword arguments (latter is recommended). Parameters: args: The positional arguments to pass to the remote API endpoint. The order of the arguments must match the order of the inputs in the Gradio app. api_name: The name of the API endpoint to call starting with a leading slash, e.g. "/predict". Does not need to be provided if the Gradio app has only one named API endpoint. fn_index: As an alternative to api_name, this parameter takes the index of the API endpoint to call, e.g. 0. Both api_name and fn_index can be provided, but if they conflict, api_name will take precedence. kwargs: The keyword arguments to pass to the remote API endpoint. Returns: The result of the API call. Will be a Tuple if the API has multiple outputs. Example: from gradio_client import Client client = Client(src="gradio/calculator") client.predict(5, "add", 4, api_name="/predict") >> 9.0 r)_infer_fn_indexr$result)rrrargskwargss rr#zClient.predicts=. Xx0t{{ Hx ;A &( rcttt|j|j|j Sr)rr rrprocess_predictionsr|)rrs r new_helperzClient.new_helpers2 F K NN8 $ 8 8 NN   r)rrresult_callbacksc |j||}|j|}t|tr!t j |j ||}d}|jdvr|j|}|j|} |jj| g|} |j|} t| ||j|j| } |r5t|t r|g}dd} |D]}| j#| || S)a Creates and returns a Job object which calls the Gradio API in a background thread. The job can be used to retrieve the status and result of the remote API call. Arguments can be provided as positional arguments or as keyword arguments (latter is recommended). Parameters: args: The arguments to pass to the remote API. The order of the arguments must match the order of the inputs in the Gradio app. api_name: The name of the API endpoint to call starting with a leading slash, e.g. "/predict". Does not need to be provided if the Gradio app has only one named API endpoint. fn_index: As an alternative to api_name, this parameter takes the index of the API endpoint to call, e.g. 0. Both api_name and fn_index can be provided, but if they conflict, api_name will take precedence. result_callbacks: A callback function, or list of callback functions, to be called when the result is ready. If a list of functions is provided, they will be called in order. The return values from the remote API are provided as separate parameters into the callback. If None, no callback will be called. kwargs: The keyword arguments to pass to the remote API endpoint. Returns: A Job object that can be used to retrieve the status and result of the remote API call. Example: from gradio_client import Client client = Client(src="gradio/calculator") job = client.submit(5, "add", 4, api_name="/predict") job.status() >> job.result() # blocking call >> 9.0 N)r:r=sse_v1sse_v2sse_v2.1r) communicatorrGrK _cancel_fncfd}|S)Nct|jtr|jy|jyr)rMrtuple)futurecallbacks rfnz,Client.submit..create_fn..fn3s/!&--/59 &--/2 1rr)r$r%s` r create_fnz Client.submit..create_fn2s2  r)returnr)rrrMrrconstruct_argsparameters_infor9rmake_end_to_end_fnrr$ make_cancelJobrGrKrr)rrrrrrinferred_fn_indexendpointhelper end_to_end_fnr# cancel_fnjobr&r$s rr$z Client.submits:!008D>>"34 h )''(@(@$OD   !  __%67F 33F; %%%m;d;((0  LL]]   *H5$4#5  - ;%%i&9: ; rctjj|jtj }|j tjdkDrtj|f|j|j|jd|j}|jr|j!}nt#d|j$d|j&tj(tj*fdt!j,|j.ddi|j}|jr|j!d}n%t#d|j$d|j&|d j1Dcic]\}}|j3d d s||c}}|d <|d j1Dcic]\}}|j3d d r||c}}|d <|Scc}}wcc}}w) Nz3.36.1rzCould not fetch api info for : rF)rd serializeapinamed_endpointsshow_apiTunnamed_endpoints)rgrhrirkrRAW_API_INFO_URLr}rVersionrrer*rLr,ra is_successrrTrZtextrSPACE_FETCHER_URLdumpsrdrpop)r api_info_urlrrfetchars rr~zClient._get_api_info@s||++D,=,=u?U?UV   gooh7 7     ## A||vvx #@ "QVVH!UVVJJ''#jj5!& ## Ezz|E* 3DHH:R |L""34::<# QjRV@WAqD#   01779% 1uuZ& qD%  !  # % s G/%G/G5ct|jd}t|jd}|dk(r|d}d}|d|dz }|jdjD]\}}||j||z }|rM|d |dz }|jdjD]#\} }||jt | |z }%n|dkDr |d |d z }|r t ||d k(r|S|d k(r |jSy) au Prints the usage info for the API. If the Gradio app has multiple API endpoints, the usage info for each endpoint will be printed separately. If return_format="dict" the info is returned in dictionary format, as shown in the example below. Parameters: all_endpoints: If True, prints information for both named and unnamed endpoints in the Gradio app. If False, will only print info about named endpoints. If None (default), will print info about named endpoints, unless there aren't any -- in which it will print info about unnamed endpoints. print_info: If True, prints the usage info to the console. If False, does not print the usage info. return_format: If None, nothing is returned. If "str", returns the same string that would be printed to the console. If "dict", returns the usage info as a dictionary that can be programmatically parsed, and *all endpoints are returned in the dictionary* regardless of the value of `all_endpoints`. The format of the dictionary is in the docstring of this method. Example: from gradio_client import Client client = Client(src="gradio/calculator") client.view_api(return_format="dict") >> { 'named_endpoints': { '/predict': { 'parameters': [ { 'label': 'num1', 'python_type': 'int | float', 'type_description': 'numeric value', 'component': 'Number', 'example_input': '5' }, { 'label': 'operation', 'python_type': 'str', 'type_description': 'string value', 'component': 'Radio', 'example_input': 'add' }, { 'label': 'num2', 'python_type': 'int | float', 'type_description': 'numeric value', 'component': 'Number', 'example_input': '5' }, ], 'returns': [ { 'label': 'output', 'python_type': 'int | float', 'type_description': 'numeric value', 'component': 'Number', }, ] }, '/flag': { 'parameters': [ ... ], 'returns': [ ... ] } } 'unnamed_endpoints': { 2: { 'parameters': [ ... ], 'returns': [ ... ] } } } } r7r9rNTz8Client.predict() Usage Info --------------------------- zNamed API endpoints: rz Unnamed API endpoints: z3, to view, run Client.view_api(all_endpoints=True) rNdict)rrr_render_endpoints_infointr]) r all_endpoints print_info return_formatnum_named_endpointsnum_unnamed_endpoints human_infor endpoint_infors rr%zClient.view_apigsXV"$**->"?@ #DJJ/B$C D ! # (= MQ -.A-B"EE '+zz2C'D'J'J'L O #Hm $55h N NJ O  56K5LBO OJ+/::6I+J+P+P+R X'-d99#h-WW  X#Q & 56K5LMAB BJ  *  E !  f $:: %rc|ttj|_|jj yr)rNrrrrrrs r reset_sessionzClient.reset_sessions' - ##%rc|js|S ddlm}|jj }|r,t |dr d|jvr|jd|d<|S#t$r|cYSwxYw)a Adds the x-ip-token header to the headers dictionary to pass it to a Zero-GPU Space. This allows a user's ZeroGPU quota to be tracked and used by the underlying Space. For the x-ip-token header to be present, this method needs to be called when a Gradio app's LocalContext is defined. i.e. this method cannot be called when the Gradio Client is instantiated, but must be called from inside a Gradio app's prediction function. r) LocalContextr*z x-ip-token)rKgradio.contextrS ImportErrorrequestrehasattrr*)rr*rSrVs rrzClient.add_zero_gpu_headerssu}}N  3 &&**, ww 2|w7V$+OOL$AGL !  N sA A.-A.c |d}|Dcgc]}|jdxs|d}}|Dcgc]}tj|}}dj|}|r|dz}|dDcgc]}|d }}|Dcgc]}tj|}}dj|} t |dkDrd| d} t |t rd |d } n!t |trd |} n td d || d| d} | dz } |r|D]} | djdr d| dddnd} | jd}tj|dtj}| jddsdnd|d}| dd}| jddr||dz }| d| ddtj| jdxs| dd |d!|d!| d" z } n| d#z } | d$z } |dr`|dD]V} | djdr d| dddnd} | dd}| d| ddtj| dd || d"z } X| S| d#z } | Scc}wcc}wcc}wcc}w)%N parametersparameter_namelabel, returnsr?()z api_name=""z fn_index=z)name_or_index must be a string or integerz - predict(z) -> rz Parameters: python_type descriptionz (r<parameter_defaultcd|ddS)Nz handle_file("rz")rxs rz/Client._render_endpoints_info.. s ahZr:rparameter_has_defaultFz (required)z(not required, defaults to: typez | Nonez - [ componentz] r4 z z - None z Returns: ) rersanitize_parameter_namesrrrMrNrHrTtraverseis_file_obj_with_meta)r name_or_indexendpoints_infoparameter_infopparameter_namesrendered_parameters return_valuesrBrendered_return_values final_paramrNrdesc default_value default_infotype_s rrGzClient._render_endpoints_infos ( 5;I 67AEE" # 1qz 1  GVV599!<VV"ii8 "5"< -;I-FG7G GDQRq77:R R!%=!9 }  !'()?(@%B " mS )&}oQ7K  s +%m_5KHI I$%8$9+eLbKccef )) & nM*..}=m,]; !%)< = %!://!  88$;UC!9-J ]+F3883U; @UY&Ek):(;2e>\>\]a]e]efv]w^I{AH|I?J>KKMNSMTTUVbUccdeidjjmnn ) n, / )J&& ) $&y1 @M*..}=m,]; ]+F3k):(;2e>\>\]abi]j>k=llnotnuvzu{{~  @ / )Jw WHRsII#, I(>I-c(|jddSNFrN)rJrKr%rs r__repr__zClient.__repr__)}}U}CCrc(|jddSr}r~rs r__str__zClient.__str__,rrczd|ji} tddtj|y#t$rYywxYw)NrZzpy_client/initiatedr0)topicr2r3 user_agent)rZrrrI Exception)rrs rrzClient._telemetry_thread/sG 488   +, % 1 1      s . ::cd}||t|jdD]:\}}|jd}||durd|z|k(s'|jd|}|Sd|d}|jds|dz }t ||:|}||j vs|j |j st d |d|S|j jDcgc]4}|j r&|j|j|jr|6} }t| d k(r| d j}|St d cc}w) Nr@rFr6rAz(Cannot find a function with `api_name`: .z% Did you mean to use a leading slash?zInvalid function index: r?rzYThis Gradio app might have multiple endpoints. Please specify an `api_name` or `fn_index`) rrdrerWrTris_validrr backend_fnr8rr) rrrr-idconfig_api_name error_messagervalid_endpointss rrzClient._infer_fn_index>s   !$++n"=> 01"#%% "3"*o.F(H4()dA%8! E 0#K8*TU V **3/!%LLM //  ! ( !7~~&78AA #;H:Q!GHH ! ..0::JJ*LL,JJ O?#q($3A$6$?$?! ! !os9D>cVt|dr|jjdyy)NrT)wait)rWrshutdownrs r__del__zClient.__del__es& 4 $ MM " " " - %rcXtj||jjSr )r space_inforHhost)rspaces rrYzClient._space_name_to_srcis))%t}}EJJJrctjtjj |j t jf|d|dd|jd|j}|jsA|jdk(rtd|j dtd|j d|jjDcic] \}}| || c}}|_ycc}}w) Nrr?)usernamepassword)rrzCould not login to z. Invalid credentials.r)rrrgrhrirZr LOGIN_URLr,rar<rrrTrLr)rrrnamers rrbz Client._loginlszz LL 5?? ; "1g47;??    3&))$((3IJ!#6txxj!BCC+/<<+=+=+? 'D%5CTD%K   s  C1"C1ctjtjj |j t jf|j|j|jd|j}|jr|jS|jdk(rtd|j d|jdk(rt j ddtj|j f|j|j|jd|j}|jst#d|j t%j&d|j(} tj*|j-d }d |vr t#d |S#t.$r}t#d |j |d}~wwxYw) NrrzCould not load z0 as credentials were not provided. Please login.iz5Too many requests to the API, please try again later.zCould not fetch config for z+window.gradio_config = (.*?);[\s]*r?z"Could not get Gradio config from: allow_flaggingzcGradio 2.x is not supported by this client. Please upgrade your Gradio app to Gradio 3.x or higher.)rrergrhrirZr CONFIG_URLr*rLr,rar<rrrTooManyRequestsErrorrTresearchr=rgroupAttributeError)rrBrrdaes rrczClient._get_config~s II LL 5+;+; < LLLL??     <<668O ]]c !%!$((+[\ ]]c !,,G      ## A<< #>txxj!IJJYYMqvvVF FLLO4  6) yM"  8 C s3$F(( G1G  Gc8 tjd|jddk(rsdgttxr dD}|st dt dk7r t d tD]\}}t|ts||f|<tfd |jjDd} | s/t d d d d |jxs |j| jD cgc]} | jr| } } | jD cgc]} | jr| } } | dgk(s| dgk(rt d| d| d} |jrFt!j"|jj$} | r|st d|jd|r0d|vr|j'dd}t!j(||}n]|jr"|jj'ddd}ndt+j,d}t!j(||}t!j.} t!j"|d}t!j4|dd|d||rt!j6|dddgit9tt;t<j>d z d!z d"#5}|jA}dddjCd$|j}|jCd%d d }|jCd&d d}tEjFd'dd"(5}tEjFd'd)5}|jI||jId*jKd+gddddddtMd,jN-tMd.jN-g}|jQ|d/d||0|rt!jR|d1||| rt!jR|d2||d3|}tUd4||Scc} wcc} w#t j0j2$rd}YwxYw#1swYxYw#1swYxYw#1swYxYw)5a Deploy the upstream app as a discord bot. Currently only supports gr.ChatInterface. Parameters: discord_bot_token: This is the "password" needed to be able to launch the bot. Users can get a token by creating a bot app on the discord website. If run the method without specifying a token, the space will explain how to get one. See here: https://huggingface.co/spaces/freddyaboulton/test-discord-bot-v1. api_names: The api_names of the app to turn into bot commands. This parameter currently has no effect as ChatInterface only has one api_name ('/chat'). to_id: The name of the space hosting the discord bot. If None, the name will be gradio-discord-bot-{random-substring} hf_token: HF api token with write priviledges in order to upload the files to HF space. Can be ommitted if logged in via the HuggingFace CLI, unless the upstream space is private. Obtain from: https://huggingface.co/settings/token private: Whether the space hosting the discord bot is private. The visibility of the discord bot itself is set via the discord website. See https://huggingface.co/spaces/freddyaboulton/test-discord-bot-v1 zThis method is deprecated and may be removed in the future. Please see the documentation on how to create a discord bot with Gradio: https://www.gradio.app/guides/creating-a-discord-bot-from-a-gradio-appmodechat_interface)chatrc3K|]P}t|txs:t|txr(t|dtxrt|dtRyw)rr?N)rMrNr").0ns r z(Client.deploy_discord..sW6  q#  1e$XAaD#)>X:aPQdTWCX 6 sAANzPEach entry in api_names must be either a string or a tuple of strings. Received r?z7Currently only one api_name can be deployed to discord.c3RK|]}|jdddk(r| yw)r6rN)r)rep api_namess rrz(Client.deploy_discord..s5 ;;Ail1o%6"77 s$'z api_name rz not present in textboxz[Currently only api_names with a single textbox as input and output are supported. Received z and FzSince zo is private, you must explicitly pass in hf_token so that it can be added as a secret in the discord bot space.r6rz-gradio-discord-botzgradio-discord-bot-Trr") repo_type space_sdkr1r5rtagszgradio-discord-bot)repo_idrmetadata templateszdiscord_chat.pyr)encodingz <>z <>z<>w)rdeleter)rrrzdiscord.py==2.3.1zapp.py) path_in_repopath_or_fileobjzrequirements.txtzDeploy Discord Bot)rcommit_messager operationsr1 DISCORD_TOKENHF_TOKENzhttps://huggingface.co/spaces/zSee your discord bot here! )+rrrdrMlistrTrrrNnextrrrKrZinput_component_typesskiprrrrrr token_hexHfApirr create_repometadata_updateopenr __file__parentreadrvtempfileNamedTemporaryFilewriterr r create_commitrr])rdiscord_bot_tokenrrrHr valid_listrrr%inpinputsoutputs is_privaterKr6 first_uploadfappapp_file requirementsrrs ` rr'zClient.deploy_discords"   Z  ;;v "2 29)*I 40 6  6   Jbclbmn  y>Q VW W + ,GAt$$ $d| !  , ..//1    IaLO,,  ( (UW  E ,,#eD E s#""499.A-B#CD E E Hhmm T /ARAR   /!     , ,/+>*-(37C(NX [[&&   5?5I& .1D $ $S )& "6@ 5J' .1D $ $S )' # $88: 00  U2 $..6"z2 & ' s ,D#D(ctfd|jjdD}|jd|dtj v}t ||j||ddk(S)Nc34K|]}|dk(s |ywrANr)rr component_ids rrz/Endpoint._get_component_type..js! 1T7l;RA s  componentsskip_apirir)rrrdrerSKIP_COMPONENTSrr)rrrjrs ` rrzEndpoint._get_component_typeisv {{)),7  ==Yv->%BWBW-WX    y ) f  (  rcx|j|jdvr|jd|jdSy)Nr7rY)rrrs rrzEndpoint._get_parameters_infots9 ==DJJ'89 9::/0? M Mrc<d|vrytj|dS)Napi_infoF)rr)rjs rrzEndpoint.value_is_fileys% Y &""9Z#899rchd|jjd|jd|jS)NzEndpoint src: z , api_name: z , fn_index: )rrZrrrs rrzEndpoint.__repr__s0 0 T]]O._inners==3355{{++.t..5+4++T2D"D/K2$22K@K[[?!::-- **11+>? ; ? s 8.post_datas( $ $(KK$<$< &rTr@cancelsct|dS)Nr?)rres rrgz&Endpoint.make_cancel..sc!A$ir)r)NNr6rz1Cancelled this job will also cancel any jobs for r\z that are currently running.zCancelling this job will not stop the server from running. To fix this, an event must be added to the upstream app that explicitly cancels this one or the upstream app must be running Gradio 4.29.0 and greater.c8gjjdS)Nrrr)rr)rrsrrz'Endpoint.make_cancel..post_datas  ($(KK$<$<rcrtjrqtjfjj jj jjdjjyy)Nr) rrrrrr*rLr,ra) cancel_msg cancellablerrrsr_cancelz%Endpoint.make_cancel.._cancelsn j) " KK// KK//;;11  kk.. r)rr}rr;rgrhrirkr CANCEL_URLrrdrrminrerrm)rr/ candidatesrdeprother_cancelledother_api_namesrrrrrrs`` @@@@@rr+zEndpoint.make_cancels >  ;; " "W__X%> >,,&&t{{'?'?AQAQRC JK68J#DKK$6$6~$FG 3==C N2%%IM1!t}}:LQMN =GJ$78L &Ho#$.KJ-#$++,,^._predicts MM $ 8 8D!MM $ 8 8I }}%y&A"LL;;00y$--P --11(;CE 66x@"*,,VXt}}M #9$--!IJJ& '?*"_ %jj1G"=7=f== "= ! KK((U+66t{{7K7KLTTT f$&/)Ao44MMQ[[MaMaLbc?@  &$VG_54?PQWPXY sE H(B)HHr'r"r)rr/rs`` rrzEndpoint.make_predicts3 !jrct|}t|jD]$\}}|js|j |d&t |Sr)rrrrinsertr")rrrinput_component_types rr zEndpoint.insert_empty_state!sNDz'01K1K'L % #A##,, At$ %T{rcg}t|D]P\}}tj|t|j|tj }|j |Rt|S)N) data_index)rrrmr _upload_filernrr")rrdata_rrs rr zEndpoint.process_input_files(sadO DAq))a8++A LLO  U|rc|jjr|j|}|jjr|j|}|j|}|Sr)rr+r-remove_skipped_componentsreduce_singleton_output)rrs rrzEndpoint.process_predictions3sZ ;; % %-$--{;K ;; ' '8$88+FK2d22K@ rc2t|}|jjdk(r:tj||j tj }t|Stj||j tj}t|S)Nr) rrr9rrm_download_filern is_file_objr")rrr5s rr+zEndpoint.download_files>stT  ;;  : -NNt**E,G,GE U|NN5$*=*=u?P?PQEU|rct||jdDcgc]\}}|js|}}}t|Scc}}w)r<F)strict)ziprrr")rrrocts rr7z"Endpoint.remove_skipped_componentsHsLdD$?$?N 388   T{  sAc|jjr'|jDcgc]}|jr|}}n |j}t |dk(r|dS|Scc}w)Nr?r)rr-rrr)rroeffective_output_componentss rr8z Endpoint.reduce_singleton_outputQse ;; ' '66+aff+ '++/*E*E ' * +q 07NK+s AAc  |d}t|}tj|s|jd| t fd|j j dDi}|j j jdd}|tjn|}tjj||kDr(td|d|d|jd d d zd t|d 5}d |j|ffg}t!j"|j j$f|j j&|j j(|j j*|d|j j,} ddd j/| j1} | d}|tj2|jddidS#1swYSxYw)NrPrc32K|]}|dk(r|ywrr)rcrs rrz(Endpoint._upload_file..cs%w,.sr max_file_sizezFile z" exceeds the maximum file size of z bytes set in r[r<z component.rbfiles)r*rLrrHr_typezgradio.FileData)rP orig_namemeta)r ris_http_url_likerrrrdremathinfrOrPgetsizerTrrrrrzr*rLr,rarr!strip_invalid_filename_characters) rrr3 file_pathrJcomponent_configrFf_rHrBrrs @rr4zEndpoint._upload_file]sfI O %%i0??84Z@L#![[// =    !KK..22?DIM(5(=DHH=Mwwy)M9 I;&HX.227B?"DE[Ri& "!INNB#789JJKK** KK// KK//;;11  kk..      VVXFq I@@P/0    s 6BGG"c|jdz|dz}|jj+tj|jjdt j }ttjtjdz }|jddtjd|f|jj|jj |jj"dd|jj$5}|j't)|t|j*z d 5}|j-d |j.z D]$}|j1||j3|& ddddddt|jj|j5z }|jdd|t|j*z } t7j8|t|j*z | t;| j=S#1swYxYw#1swYxYw) Nzfile=rPTr4r)r5parentsr)r*rLrfollow_redirectswb) chunk_size)rrrUrOrRhashlibsha256r r gettempdirrrmkdirrrr*rLr,rarrrr block_sizerJr hexdigestshutilmoverNresolve) rrfurl_pathshatemp_dirrrr directorydests rr:zEndpoint._download_files==7*QvY6 ;; ! ! - KK .. >nn++-.1B1B21FFd3 \\   KK''KK'';;))!  kk&& #  % % 'hh!4!44d; #q%00C#..... HtH~222D94<<>"" # # # #s%3IAIII IIc tjdtjd|jjd|jj 5}t j|||||jj|jj|jj|jj|jj|jj cdddS#1swYyxYw)Nr)rrr) rr)rrr,rarget_pred_from_sse_v0rprur*rLr)rrrr/rs rr'zEndpoint._sse_fn_v0s \\ MM$/;;)) kk&&  -- ## (( ## ## && $$     s BC55C>c tj||jj|jj|jj |||jj |jjSr)rget_pred_from_sse_v1plusrr*rLrr,r)rr/rr9s rr)zEndpoint._sse_fn_v1plussa --  KK   KK   KK 2 2   KK " " KK   r)r)rr)rrHrrFr9rN)rrH)r'zlist[ParameterInfo] | None)rjrFr'rr)r/Communicator | Noner.)r'r )rrFr3rHr'r)rfrFr'rN)rrFrrFr/r)r/rrrNr9r)rrrrrrr staticmethodrrrr*r+rr r rr+r7r8r4r:r'r)rrrrrLsSPX33(+39=3IL34   ::h.G#GR6p   ' R#<&   D  rrrrstatuscxeZdZdZ d d dZd dZd dZddfd ZddZddZ ddZ d Z xZ S)r,a A Job is a wrapper over the Future class that represents a prediction call that has been submitted by the Gradio client. This class is not meant to be instantiated directly, but rather is created by the Client.submit() method. A Job object includes methods to get the status of the prediction call, as well to get the outputs of the prediction call. Job objects are also iterable, and can be used in a loop to get the outputs of prediction calls as they become available for generator endpoints. cX||_||_d|_||_||_||_y)a Parameters: future: The future object that represents the prediction call, created by the Client.submit() method communicator: The communicator object that is used to communicate between the client and the background thread running the job verbose: Whether to print any status-related messages to the console space_id: The space ID corresponding to the Client object that created this Job object rN)r#r_counterrGrKr1)rr#rrGrKrs rrz Job.__init__s/ (    #rc|Srrrs r__iter__z Job.__iter__s rc|js t |jj5t|jjj |j dzk\rM|jjj |j }|xj dz c_|cdddS|jjjjtjk(r@|j t|jjj k\r ttjdddd7#1swY xYw)Nr?gMbP?) r StopIterationr rr2rrq latest_statuscoderFINISHEDr^r_)rrAs r__next__z Job.__next__s  / !""'' "t((,,4459JJ))--55dmmDAMMQ&M " " %%))77<<O T->->-B-B-J-J)KK'/) 5! " " "sA=E5BEEc$t||S)a. Return the result of the call that the future represents. Raises CancelledError: If the future was cancelled, TimeoutError: If the future didn't finish executing before the given timeout, and Exception: If the call raised then that exception will be raised. Parameters: timeout: The number of seconds to wait for the result if the future isn't done. If None, then there is no limit on the wait time. Returns: The result of the call that the future represents. For generator functions, it will return the final iteration. Example: from gradio_client import Client calculator = Client(src="gradio/calculator") job = calculator.submit("foo", "add", 4, fn_index=0) job.result(timeout=5) >> 9 r)superr)rr __class__s rrz Job.resultsw~g~..rc|jsgS|jj5|jjjcdddS#1swYyxYw)a Returns a list containing the latest outputs from the Job. If the endpoint has multiple output components, the list will contain a tuple of results. Otherwise, it will contain the results without storing them in tuples. For endpoints that are queued, this list will contain the final job output even if that endpoint does not use a generator function. Example: from gradio_client import Client client = Client(src="gradio/count_generator") job = client.submit(3, api_name="/count") while not job.done(): time.sleep(0.1) job.outputs() >> ['0', '1', '2'] N)rr r2rrs rrz Job.outputssK(  I""'' 5((,,44 5 5 5s AAc tj}d}|jr5|jj5|jj}ddd|r t t jddd|ddS|jrV|jjs t t jddd|ddSt t jddd|ddS|js t t jddd|ddS|jj5|jjjj}|j r8|j"r,|r*|dkDr%t%dt'|d|j"d |jjjcdddS#1swYlxYw#1swYyxYw) a< Returns the latest status update from the Job in the form of a StatusUpdate object, which contains the following fields: code, rank, queue_size, success, time, eta, and progress_data. progress_data is a list of updates emitted by the gr.Progress() tracker of the event handler. Each element of the list has the following fields: index, length, unit, progress, desc. If the event handler does not have a gr.Progress() tracker, the progress_data field will be None. Example: from gradio_client import Client client = Client(src="gradio/calculator") job = client.submit(5, "add", 4, api_name="/predict") job.status() >> job.status().eta >> 43.241 # seconds FNr)rwrank queue_sizesuccessr^eta progress_dataTzIDue to heavy traffic on this app, the prediction will take approximately zn seconds.For faster predictions without waiting in queue, you may duplicate the space using: Client.duplicate(r_)rnowrr  should_cancelr r CANCELLEDrr# _exceptionrx PROCESSINGr2rvrrGrKr]rH)rr^ cancelledrs rrnz Job.status*s$||~   ""'' < --;;  < %%"  99;;;))## "&$#!"&""&&" ""'' ;''++99==<>NN$    {{!!##   s /A55A>c.t|j|S)z,Forwards any properties to the Future class.)getattrr#)rrs r __getattr__zJob.__getattr__st{{D))r)NTNN) r#rrrlrGrrKrrzCallable[[], None] | None)r'r,)r'z tuple | Anyr)rz float | Noner'r )r'zlist[tuple | Any])r'r )r'r) rrrrrrsryrrrnrr __classcell__)r|s@rr,r,sp-1#04 $$*$ $  $ . $,""/"54H;T$.*rr,)Ir __future__rconcurrent.futuresrrZrrMrOrrr`rrr^ urllib.parsergrrcollections.abcrr dataclassesrr functoolsrpathlibr r typingr r rrr rrhuggingface_hub.utilsrrr packagingrr0rgradio_client.compatibilityrgradio_client.data_classesrgradio_client.documentationrgradio_client.exceptionsrrgradio_client.utilsrrrrrrr environrerNr\rVr)rrrr,rrrrsS2"    $%! II ?40B::>>"34    (*9  )Xz;8HIBBJBJ      z z z  (Ix(C*&C*)C*r