XjddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlZddlmZddlmZmZddlmZmZddlmZddlmZddlm Z dd l!m"Z"dd l#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,ddl-Z.ddl/Z/ddl0Z0dd l0m1Z1e$rdd l2m3Z3d Z4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAdZBdZCdZDe1jEe1jFe1jGe1jHe1jIgZJe jKdZLeMddddd d!hd"d#Dd$d#DZNGd%d&e(d'(ZOdd+ZPePZQGd,d-eRZSGd.d/eRZTGd0d1eRZUGd2d3eRZVGd4d5eWeZXGd6d7eZYeGd8d9ZZeGd:d;Z[eGd<d=Z\e'd>e[e\zZ]d?Z^eGd@dAZ_eGdBdCZ`ddEZaddGZbddHZcddYZdddaZeddbZfdddZgddfZhdgZidddkZj dddnZkddpZlddrZmdduZnddxZoddzZpdd|Zqddd}ZrddZsdddZtddZuddZv dddZwdddZxddZy dddZzddZ{Gdde|Z}ddZ~gdZedZddZddZddZddZddZddZddZddZdddZddZddZddZddZddZhdZddZddZddZddZdS)) annotationsN)deque)Callable Coroutine) dataclassfield)datetime)Enum)Path)Lock) TYPE_CHECKINGAnyLiteralNewType TypedDictUnionget_args get_originget_type_hints) SpaceStage) ParameterInfoz api/predict/z queue/joinz queue/datauploadloginconfigzinfo?all_endpoints=Truezinfo?serialize=Falsez0https://gradio-space-api-fetcher-v2.hf.space/apiresetzhttps://hf.space/{}zheartbeat/{session_hash}cancelstatez[<>:"/\\|?*\x00-\x1f\x7f`$!{}]CONPRNAUXNULzCONIN$zCONOUT$c# K|] }d|V dS)COMN.0cs DC:\Projects\Historical\venv\Lib\site-packages\gradio_client/utils.py r)Y( 5 5))) 5 5 5 5 5 5u123456789¹²³c# K|] }d|V dS)LPTNr$r%s r(r)r)Zr*r+cteZdZUded<ded<ded<ded<ded <ded <d ed <d ed<ded<ded<dS)Messagestrmsgdict[str, Any]outputevent_idintrankfloatrank_eta queue_sizeboolsuccess list[dict] progress_dataloglevelN)__name__ __module__ __qualname____annotations__r$r+r(r/r/_sp HHHMMM IIIOOOOOOMMM HHHJJJJJr+r/F)totalreturnr0c tjtdd}t j|}|dd}|S#t$rYdSwxYw)Nz package.jsonutf-8version) pkgutilget_datar@decodestripjsonloadsget Exception)package_json_data package_datarHs r(get_package_versionrTls  X~ 6 6 = =g F F L L N N z"344 ""9b11 rrsA*A-- A;:A;ceZdZdZdS)TooManyRequestsErrorz.Raised when the API returns a 429 status code.Nr@rArB__doc__r$r+r(rVrV{s88Dr+rVceZdZdZdS) QueueErrorzMRaised when the queue is full or there is an issue adding a job to the queue.NrWr$r+r(rZrZsWWDr+rZceZdZdZdS)InvalidAPIEndpointErrorz(Raised when the API endpoint is invalid.NrWr$r+r(r\r\s22Dr+r\ceZdZdZdS)SpaceDuplicationErrorz:Raised when something goes wrong with a Space Duplication.NrWr$r+r(r^r^sDDDr+r^cFeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdS) ServerMessage send_hash queue_full estimation send_dataprocess_startsprocess_generatingprocess_completedr>progress heartbeatzServer stopped unexpectedly.unexpected_error close_streamprocess_streamingN)r@rArBrarbrcrdrerfrgr>rhriserver_stoppedrjrkrlr$r+r(r`r`sZIJJI%N-+ CHI3N)!L+r+r`cveZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d ZeddZddZeddZdS)Statusz'Status codes presented to client users.STARTING JOINING_QUEUE QUEUE_FULLIN_QUEUE SENDING_DATA PROCESSING ITERATINGPROGRESSFINISHED CANCELLEDLOGstatusrEr5c  tjtjtjtjtjtjtjtjtj tj g }| |S)z'Order of messages. Helpful for testing.) rorprqrrrsrtrurwrvrxryindex)r{orders r(orderingzStatus.orderingsW O    O     O   O    {{6"""r+othercZ||||kSN)r)selfrs r(__lt__z Status.__lt__s%}}T""T]]5%9%999r+r1r0ctjtjtjtjtjtjtjtj tj tj tj tj tjtjtjtjtjtjtjtji |S)zKMap the raw message from the backend to the status code presented to users.)r`rarorqrbrrrcrsrdrtrerurfrvrgrxrhrwr>rzrm)r1s r( msg_to_statuszStatus.msg_to_statuss  #V%9  $f&7  $fo  #V%8  (&*;  ,f.>  +V_  "FO  vz  (&/     r+N)r{rorEr5)rro)r1r0rEro)r@rArBrXrprqrrrsrtrurvrwrxryrz staticmethodrrrr$r+r(roros11H#MJH!LJIHHI C###\# ::::   \   r+rocZeZdZUded<ded<ded<ded<ded<edd ZdS) ProgressUnit int | Noner}length str | Noneunit float | Nonerhdescdatar<rElist[ProgressUnit]c fd|DS)Nc g|]q}|d|d|d|d|drS)r}rrrhr)r}rrrhrrP)r&dclss r( z)ProgressUnit.from_msg..s     CeeGnnuuXUU6]]z**UU6]]        r+r$)rrs` r(from_msgzProgressUnit.from_msgs0         r+N)rr<rEr)r@rArBrC classmethodrr$r+r(rrsp    [    r+rcveZdZUdZded<ded<ded<ded<d ed <d ed <d ed<dZded<dZded<dS) StatusUpdateIUpdate message sent from the worker thread to the Job on the main thread.rocoderr6r9retaz bool | Noner;zdatetime | Nonetimezlist[ProgressUnit] | Noner=Nztuple[str, str] | Noner>r{zLiteral['status', 'output']type)r@rArBrXrCr>rr$r+r(rrsSSLLL,,,,"&C&&&&(0D000000r+rcDeZdZUdZded<ded<dZded<d Zded <d S) OutputUpdater list[Any]outputsr:r;r3zLiteral['output']rFfinalN)r@rArBrXrCrrr$r+r(rrsOSSMMM&D&&&&Er+rUpdatec dttjddddtjdS)N)rr6r9rr;rr=)rrorpr nowr$r+r(create_initial_status_updater s6  _   \^^   r+cXeZdZUdZeeZded<eeZ ded<dS) JobStatuszpThe job status. Keeps track of the latest status update and intermediate outputs (not yet implements). default_factoryr latest_statusrrN) r@rArBrXrrrrClistrr$r+r(rrs[ #(%8T"U"U"UMUUUUt444G444444r+rceZdZUdZded<ded<ded<ded <d Zd ed <d Zded<d Zd ed<d Zded<e e j Z ded<d S) CommunicatorzKHelper class to help communicate between the worker thread and main thread.r lockrjobzCallable[..., tuple]prediction_processorr0 reset_urlFr: should_cancelNrr4thread_completedict[str, str] | Nonerequest_headersrzasyncio.Queue[Update]updates) r@rArBrXrCrr4rrrasyncioQueuerr$r+r(rr!sUUJJJNNN....NNNMH!O!!!!-1O1111%*U7=%I%I%IGIIIIIIr+rr:cZt|tsdS|dS)zN Check if the given value is a string that looks like an HTTP(S) URL. F)zhttp://zhttps://) isinstancer0 startswith possible_urls r(is_http_url_liker5s0 lC ( (u  " "#: ; ;;r+rc(ddi} tj5}tj||}|jdkr(|||jcdddS|jcdddS#1swxYwYdS#t $rYdSwxYw)zb Probe the given URL to see if it responds with a 200 status code (to HEAD, then to GET). z User-Agentz8gradio (https://gradio.app/; gradio-team@huggingface.co)headersiNF)httpxClienthead status_coderP is_successrQ)rrclient head_requests r( probe_urlr>s WXG \^^ +v :lGDDDL'3..zz,z@@K + + + + + + + + *  + + + + + + + + + + + + + + + + + + uus@B=A6 B#A6) B6A::B=A:>B BBcftjdt|ot|S)z3 Check if the given string is a valid URL. z^is_valid_url should not be used. Use is_http_url_like() and probe_url(), as suitable, instead.)warningswarnrrrs r( is_valid_urlrMs; M H L ) ) Ei .E.EEr+r httpx.Clientrdict hash_datahelpersse_url sse_data_urlrdict[str, str]cookiesr ssl_verifyexecutor%concurrent.futures.ThreadPoolExecutordict[str, Any] | Nonec d|_| t||||} | t|||||||| } tj| | gtjj\} } d|_t| dkr tdt| d| D]}| cSdSNF) return_whenTzDid not expect z tasks to be done.) rsubmitcheck_for_cancel stream_sse_v0 concurrentfutureswaitFIRST_COMPLETEDlen ValueErrorresult)rrrrrrrrrr future_cancel future_ssedone_futures r(get_pred_from_sse_v0rXs#FOO&'7JM   J %%  #&6&GD!"F 4yyA~~H3t99HHHIII}}r+pending_messages_per_event dict[str, deque[Message | None]] pending_lockr r4protocol'Literal['sse_v1', 'sse_v2', 'sse_v2.1']c d|_|t||||} |t|||||} tj| | gtjj\} } d|_t| dkr tdt| d| D]:} | }|r ~ ~ ~ ~ |#~wxYw| cSdSr) rrrstream_sse_v1plusrrrrrr exceptionr)rrrrrr4rrrrrrrrrs r(get_pred_from_sse_v1plusrs%#FOO&'7JM" J %%  #&6&GD!"F 4yyA~~H3t99HHHIII  $$&&   z4  }}  s CCct tjd|j5|jr dddn>|jrt j dddn #1swxYwYn|jr%tj |j d|ji|||t j)NT皙?r4)rNrrverify) rsleeprrrrrCancelledErrorr4rpostr)rrrrs r(rrs& : 4 [ : :#  : : : : : : :% : (77999 : : : : : : : : : : : : : : : ::   fo.        + + - --s A$%A$$A(+A(r2c> |d||||5}|D]} | d} t| dkr,| drZt j| dd} | dtjtj fvr|j 5d| v} tt | d| d | d d| d tj| d | r t"| dnd } | didg} | rZ| jtjkrE |j| }n#t,$r }|g}Yd}~nd}~wwxYw|jj|| |j_dddn #1swxYwY|jrt8j| ddkrt?d| ddkrD| d}||_ |!|d|i||||}|"x| ddkr| dccdddStGd|  dddn #1swxYwYtGd#t8jj$rwxYw)NGET)paramsrr rdata:r1r=r9r6r;r8)rr9r6r;rrr=r3rrbz Queue is full! Please try again.rdr4)rNrrrgzUnexpected message: z*Did not receive process_completed message.)$stream iter_linesrstriprrrNrOr`r>rirrrorrPr rrrrrxrrQrrappendrrrrrrZr4rraise_for_statusr)rrrrrrrrresponselineresp has_progress status_updater3rer4reqs r(rrs"9 ]]     5 D  ++--. D. D{{4((t99>>??7++*D:d122h//DE{}'8-:Q&RRR AA'6$'> (4!'!5!5d5k!B!B'+xx '='=!%&$!7!7$(HHY$7$7!) $ 4 4++&,*?*?_@U*V*V*V!% ) ) ) "&(B!7!7!;!;FB!G!G!>m&8FO&K&K-)D)Df)M#,---*+-"J.55f===3@ 0)AAAAAAAAAAAAAAA*-B(0??AAAE{l22()KLLLe 33#' #3*2$kk(",h!L$!L)!L$+$+ * ,,....e(;;;#H~--g5 D5 D5 D5 D5 D5 D5 D5 Dd<%%BD%B%BCCC]. D5 D5 D5 D5 D5 D5 D5 D5 D5 D5 D5 D5 D5 D5 D5 DlEFFF   , sLBK,7C:H2 F=<H= G G HG .H K,H K,H B(K,> L K, L,K00L3K04LL1Literal['sse_v1', 'sse_v2', 'sse_v2.1', 'sse_v3']c  ||}d} t|dkr|}ntjd>||jrt j|j5d}|dtj kr2| d} | d} | r| r| | f}tt|d| d| dd| d tj| d d |vr t"|d nd| } | d i dg} |dtjkru|dvrq|t)| }n_t+| D]O\} }| t|kr|d|| }t/||}||| <|| | <P| r| jtjkr |j| }n#t6$r }|g}Yd}~nd}~wwxYw|jj||jtA|| d d| |j_!|j| dddn #1swxYwY|dtj"kr|5||=dddn #1swxYwY| d ds(tG|d $} n|d } |jtA| d| d d|d S|dtj%krtMd#t jj$rwxYw)NTrrr1r>r?r9r6r;r8r=)rr9r6r;rrr=r>r3r)sse_v2zsse_v2.1sse_v3)rr;)rrr;zServer stopped.)'rpopleftrrrrrrrr`r>rPrrorr rrrrfr enumerater  apply_diffrrxrrQrrr put_nowaitrrrgritemsrmr)rrrr4rpending_messagespending_responses_for_diffsr1 log_messager>r?rr3ivalue prev_output new_outputrrs r(rr sV5h?&*#O 4#$$q((&..00 4   {f4{ (779992 92 9" u:!222''%..CGGG,,E3u3'*El ,--c%j99"ww|44..GGI..! ++&#--#/"7"7O8L"M"M"M# ! ! ! 2..2262>>u:!AAAhSGG 3:6:6ll33(1&(9(9 3 3HAu !C(C$D$DDD ; B B4 H H H*Ea*HK)3K)G)GJ=G7:(2F1IIm0FOCC%!<!>O+K>O+L-! O+-L11O+4L15BO+'O++Pcbtj|}d}|D]\}}}|||||}|S)Nc>t|dkr%|dkr|S|dkr||zStd||}tt|dz D]}|||}|d}|dkr|||<n|dkr||xx|z cc<n|dkr?t|tr$|t ||nH|||<nB|dkr*t|tr|t |=n||=ntd ||S) Nrreplacer zUnsupported action: radddeletezUnknown action: )rrrangerrinsertr5)targetpathactionr currentr last_paths r( apply_editzapply_diff..apply_editlsh t99>>"" 8##~% !@!@!@AAAs4yy1}%% ' 'Ad1g&GGH Y  !&GI   x   I   % '     u__'4(( +s9~~u5555%* "" x  '4(( 'C NN++I&&88899 9 r+)copydeepcopy)objdiffr0r-r,r s r(rrisU -  CB $33ejdFE22 Jr+ file_pathdirrc8t|ptjtjdz }|dd|t|jz }tj||t| S)NTexist_okparents) r tempfile gettempdirsecrets token_hexmkdirnameshutilcopy2r0resolve)r5r6 directorydests r(create_tmp_copy_of_filerGs~S1H/1122W5Fr5J5JJI OOT4O000 tI+ +D LD!!! t||~~  r+url_pathtokenc|tj|d|rdd|zini}t|ptjt jdz }|dd|t|jz }tj d||d 5}| t|d 5}| D]}|| dddn #1swxYwYdddn #1swxYwYt|S) z0Kept for backwards compatibility for 3.x spaces.NTr: AuthorizationBearer r8r9r)rfollow_redirectswb)osmakedirsr r<r=r>r?r@rArrr openiter_rawwriter0rD) rHrIr6rrEr5r fchunks r(download_tmp_copy_of_filerWs  C$''''6;C E 122GS1H/1122W5Fr5J5JJI OOT4O000DNN//I  x4    !!### )T " " a!**,,                    y  "" # ##s6!%D-D4 DD DD DDDfilenamec|}|drdS|drdStj|d}|*|dddd }|S) Nz.vttztext/vttz.webpz image/webprzx-wavwavzx-flacflac)lowerendswith mimetypes guess_typer%)rXfilename_lowermimetypes r( get_mimetyperbs^^%%Nv&&zw''|#H--a0H##GU33;;HfMM Or+encodingc|dd}tj|d}|dkrdS|dStj|}||dr |dd}|S)Nz audio/wavz audio/x-wavrz audio/flacr[.r)r%r^r_guess_extensionr)rcr extensions r( get_extensionrhs ];;H   ) )! ,D |v t)$//I!5!5c!:!:abbM r+ file_types list[str]ct|}t|j}|D]}|dkrdS|drM|}t |t |kr||rdSm|||drdSdS)NfileTre/F)rbr rAr\rrr])r5ri mime_type file_name file_types r( is_valid_filerqsY''IY$**,,I   44    $ $ !))I9~~I..93E3Ei3P3P.tt  "y';';yOOO'L'L "44 5r+rU str | Pathct|d5}tj|}t |d}t t |}d||ndzdz|z cdddS#1swxYwYdS)NrbrGrrI;base64,)rRbase64 b64encodereadr0rb)rUrlencoded_string base64_strras r(encode_file_to_base64r{s a  $)$))++6611 A'' #/xxR 9                     sA"BBBurlctj|}|tj|j}t |d}t|}d||ndzdz|zS)NrGrrIru)rrPr rvrwcontentr0rb)r|rryrzras r(encode_url_to_base64rso 9S>>D%dl33N^W--JC  Hx388.Hs*RRR$4<<>>RTT\\\\\r+rr)joinr%r\)rs r(sanitize_parameter_namesrEs? RR-RRRSS c   r+str | Path | NoneprefixcZt|ptjtjdz }|ddt |\}}|Y|Wt|j}|}d|vr=|d|d}||ddzd}|t|}|tj d||}ntj d|d|z| }| || |S) Nr8Tr9rerrF)r(rr6)r(rsuffixr6) r r<r=r>r?r@rrAr}rNamedTemporaryFilerTflush) rcr5r6rrErrgrXfile_objs r(decode_base64_to_filerNsC S1H/1122W5Fr5J5JJI OOT4O000-h77OD) ??' (??a(.."5"556F !4!4q!8!:!:;I 26::.Y   .?      NN4 NN Or+jsnstr | dict | listc |tj|dtjdd|d}t |t rt j|}t j||| |S)NTrKFz.jsonzw+)r(rr6mode) rPrQr<rrr0rNrOdumpr)rr6rs r(dict_or_str_to_json_filerqs  C$''''*W#DH#sjooIc8 NN Or+ dict | listc|t|5}tj|cdddS#1swxYwYdSr)rRrNload)r5rUs r( file_to_jsonrsz iAy||s 155,space_idtimeout_in_secondsctj|dt} t jd|dd|i|dS#tj$r1}tdt |d|d}~wwxYw) N gradio_client)rI library_namelibrary_versionz"https://huggingface.co/api/spaces/z /sleeptimeseconds)rNrz>Could not set sleep timeout on duplicated Space. Please visit z5 to set a timeout manually to reduce billing charges.) huggingface_hubutilsbuild_hf_headers __version__rrHTTPStatusErrorr^ SPACE_URLformat)rrIrrrs r(set_space_timeoutrs #44$#5G  E E E E/0       # CYM]M]^fMgMg C C C   sAB,BBfuncrrcptjjtj|g|Ri|S)a Runs async functions in sync scopes. Can be used in any scope. Example: if inspect.iscoroutinefunction(block_fn.fn): predictions = utils.synchronize_async(block_fn.fn, *processed_input) Args: func: *args: **kwargs: )fsspecasynsyncget_loop)rargskwargss r(synchronize_asyncrs7 ; FK0022D J4 J J J6 J JJr+ceZdZdS)APIInfoParseErrorN)r@rArBr$r+r(rrsDr+rschemacd|vrdSd|vrdSd|vr|dS|drdS|drdS|drdS|drdSd|vriStd|) Nconstenumr$refoneOfanyOfallOfzCannot parse type for )rPr)rs r(get_typers&w v 6  f~ F   Cv G   Cw G  Cw G  Cw v    A A ABBBr+)a-Dict(path: str | None (Path to a local file), url: str | None (Publicly available url or base64 encoded image), size: int | None (Size of image in bytes), orig_name: str | None (Original filename), mime_type: str | None (mime type of image), is_stream: bool (Can always be set to False), meta: Dict())a-dict(path: str | None (Path to a local file), url: str | None (Publicly available url or base64 encoded image), size: int | None (Size of image in bytes), orig_name: str | None (Original filename), mime_type: str | None (mime type of image), is_stream: bool (Can always be set to False), meta: dict())z`Dict(path: str, url: str | None, size: int | None, orig_name: str | None, mime_type: str | None)zqDict(path: str, url: str | None, size: int | None, orig_name: str | None, mime_type: str | None, is_stream: bool)zDict(path: str, url: str | None, size: int | None, orig_name: str | None, mime_type: str | None, is_stream: bool, meta: Dict())zdict(path: str, url: str | None, size: int | None, orig_name: str | None, mime_type: str | None, is_stream: bool, meta: dict())zdict(path: str, url: str | None, size: int | None, orig_name: str | None, mime_type: str | None, is_stream: bool, meta: dict(_type: Literal[gradio.FileData]))r&c~t||d}|tdS)N$defsfilepath)_json_schema_to_python_typerPr%CURRENT_FILE_DATA_FORMAT)rtype_s r(json_schema_to_python_typers2 ' 70C0C D DE ==1: > >>r+c4 |ikrdSt|}|ikrd|divrdSdS|dkr5t|dddS|dkrd S|d kr d |d d S|d kr+d dd|d Dzd zS|dkrdS|dkrdS|dkrdS|dkrdS|dkr|dg}d|vr-dfd|dD}d|d Sd|vr-dfd|dD}d|d St|}d|d S|dkr|d i}t |pird!Sd"  fd#|D}d$|vr=|d$}t|tr |r|d%gz }n|d&t|gz }d|}d'|d(S|d)vr)d*fd+||D}|S|d,kr/dfd-||D} d.| d }|Std/|)0z/Convert the json schema into a python type hintrrN descriptionz str | float | bool | list | dictrrmr&nullNonerzLiteral[]rz, c8g|]}dt|zdzS)')r0)r&vs r(rz/_json_schema_to_python_type..s'#O#O#O1C#a&&L3$6#O#O#Or+integerr5stringr0booleanr:numberr7arrayr prefixItemsc0g|]}t|Sr$rr&rdefss r(rz/_json_schema_to_python_type..s$TTT!,Q55TTTr+ztuple[c0g|]}t|Sr$rrs r(rz/_json_schema_to_python_type..s$UUU!,Q55UUUr+zlist[object propertiesrcb|drd|ddndS)Nrz ()rIr)rs r(get_descz-_json_schema_to_python_type..get_descs634553G3GO/m,,////R Or+cbg|]+\}}|dk |dt||,S)r: r)r&nrrrs r(rz/_json_schema_to_python_type..sT   1G|| G G/488 G((1++ G G||r+additionalPropertieszstr, Anyzstr, zdict(r)rrz | c0g|]}t|Sr$rrs r(rz/_json_schema_to_python_type.."s$WWWA6q$??WWWr+rc38K|]}t|VdSrrrs r(r)z._json_schema_to_python_type..%s.UU!4Q==UUUUUUr+zAll[zCannot parse schema ) rrPrsplitr_is_file_schemarrr:r) rrrrelementspropsdesadditional_propertiesrrrs ` @r(rrs ||u V  E {{ VZZ r22 2 2555 &*4v0D0DS0I0I"0M+NPTUUU &v '  ,&/,,,, & #O#Ov#O#O#OPP PSV V  )  u (  u )  v (  w '   7B'' E ! !yyTTTTu]?STTTH(H''' ' f $ $yyUUUUvm?TUUUH(H''' '25$??H&8&&& & (   <,, 64:2 . . : P P P          "V + +$*+A$B !/66 ;P  |#V78MtTTVViinns~~~ $ $ $zzWWWWPUWWWXX '  yyUUUUve}UUUUUd~~~  ?v ? ?@@@r+ type_hintcF t|S#t$ricYSwxYwr)_python_type_to_json_schemarQ)r s r(python_type_to_json_schemar ,s9*9555  s   c|tdurddiS|turiS|turddiS|turddiS|turddiS|t urddiS|t urdid S|turd id S|turdd iS|tus |turd d d S|tus |turdddSt|}|tur=t|}t!|dkr d|diSdt|iS|t"us.t%|dr |jdkst|dkrqt|}t!|dkrAtd|vr0t)d|D}t+|}dddi|giSdd|DiS|tur0t|}|sd id S|d}d t+|d S|turut|}|sdd iSt!|dkr"|ddurd t+|dd Sd d|Dt!|t!|dS|tus |tur1t|}|sd d d S|d}d d t+|dS|t urGt|}|sdid S|\}} |turt-d dt+| d }|St/j|r%t3|t4rd!|D} d| iSt/j|rt%|d"ri} g} t7|} | D]{\}}t+|| |<t%|d#r|jr| |Dt%|d$r|j|j s| ||d| d%}| r| |d&<|SiS)'z,Convert a Python type hint to a JSON schema.Nrrrrrrr)rrr)rrT)r uniqueItemsbyte)rrrrrrr@ UnionType|c3<K|]}|tdu|VdSr)rr&ts r(r)z._python_type_to_json_schema..[s2FFA!4::2E2Ea2E2E2E2EFFr+rrc,g|]}t|Sr$r rs r(rz/_python_type_to_json_schema..^s!HHHQ5a88HHHr+.c,g|]}t|Sr$rrs r(rz/_python_type_to_json_schema..ns!JJJq7::JJJr+)rrminItemsmaxItems)rrrz0JSON Schema only supports string keys in objectscg|] }|j Sr$)r )r&items r(rz/_python_type_to_json_schema..s888dtz888r+rC __total____dataclass_fields__)rrrequired)!rrr0r5r7r:rrtupleset frozensetbytesrrrrrrhasattrr@nextr rinspectisclass issubclassr rrrr rdefault)r originliteral_valuestypes other_typerr item_typekey_type value_type enum_valuesrr hints field_name field_types r(r r 3s"DJJC C!!C ""E!!D ""D "===D"---E  C9 11555EY)33 F333  " "F !),, ~  ! # #^A./ /^,,-- % FJ ' ' ,2O{,J,J v;;#  ## u::??tDzzU22FFFFFFFJ0<> , 5jAI , +++"*==  *!)F:  Ir+json_objis_rootCallable[..., bool]cR||r ||St|tr2i}|D]\}}t|||||<|St|tt fr-g}|D]&}|t|||'|S|S)zk Traverse a JSON object and apply a function to each element that satisfies the is_root condition. )rrrtraverserr!r r6rr7new_objkeyr rs r(r:r:swx tH~~ Hd # # "..** : :JC#E499GCLL HtUm , , : :D NN8D$88 9 9 9 9r+'Callable[..., Coroutine[Any, Any, Any]]czK||r||d{VSt|tr8i}|D]\}}t|||d{V||< |St|tt fr3g}|D],}|t|||d{V-|S|S)zq Traverse a JSON object and apply a async function to each element that satisfies the is_root condition. N)rrrasync_traverserr!r r;s r(r@r@swx T(^^####### Hd # # "..** F FJC!/tW!E!EEEEEEEGCLL HtUm , , F FD NNdG!D!DDDDDDD E E E Er+api_infocJt||diS)Nr)_schema_contains_filerP)rAs r( value_is_filerDs 8<<+D+D E EEr+rchd|vr-|ddd}||vr||S|S)z!Resolve a $ref to its definition.rrmr&)rrrref_names r( _resolve_refrHsC &>'',,R0 t  > ! Mr+ dict | Nonec||di}|di}d|vsd|vrdSt|d|}|di}d|vr!|d}|dd kS|d i}t|tr|dd kSdS) zYCheck if a schema directly represents a file type (has path + meta with gradio.FileData).Nrrr,metaF_typergradio.FileDatar*)rPrHrr)rrrrK meta_props type_schema meta_defaults r(rrs |zz'2&& JJ|R ( (E UfE11u f t , ,D,++J* ) w''+<<<88Ir**L,%%>((,=== 5r+ct|ts2t|trtfd|DSdSd|vr=|ddd}|vrt |SdSt |rdStfd|DS)zARecursively check if a JSON schema contains a file type anywhere.c38K|]}t|VdSr)rC)r&rrs r(r)z(_schema_contains_file..s.LLT,T488LLLLLLr+Frrmr&Tc3K|]9\}}|dk t|ttf't|V:dS)rN)rrrrC)r&krrs r(r)z(_schema_contains_file..sU Aq <'',,R0 t  (h>> >uvt$$t LLNN  r+ct|ttfoAt|o t|S)zp Check if the given value is a valid str or Path filepath on the local filesystem, e.g. "path/to/file". )rr0r existsis_file)ss r( is_filepathrZsB a#t % % P$q''..*:*: PtAww?P?PPr+cjt|tod|vot|dtS)z Check if the given value is a valid FileData object dictionary in versions of Gradio<=4.20, e.g. { "path": "path/to/file", } r,)rrr0rs r( is_file_objr] s0 a   M6Q; M:ai3M3MMr+ct|toBd|vo>t|dto#d|vo|ddddkS)z Check if the given value is a valid FileData object dictionary in newer versions of Gradio where the file objects include a specific "meta" key, e.g. { "path": "path/to/file", "meta": {"_type: "gradio.FileData"} } r,rKrLrIrM)rrr0rPr\s r(is_file_obj_with_metar_sh 1d < aK < qy# & & < aK < fIMM'2 & &*; ; r+c^t|od|vot|dtS)a> Check if the given value is a valid FileData object dictionary in newer versions of Gradio where the file objects include a specific "meta" key, and ALSO include a "url" key, e.g. { "path": "path/to/file", "url": "/file=path/to/file", "meta": {"_type: "gradio.FileData"} } r|)r_rr0r\s r(is_file_obj_with_urlra(s. ! # # P Pz!E(C7P7PPr+> boxrowtabformtabsgrouprcolumndatasetsidebartabitem accordioninterpretationfilepath_or_urlc0t|}|ddid}t|r$i||ddd|dSt|ri|d t|jiSt d |d ) NrLrM)r,rKrmr)maxsplitr&) orig_namer|rqzFile z; does not exist on local filesystem and is not a valid URL.)r0rrr rWrAr)rnrYrs r( handle_filerrFs OA):; < %>r%B1MMMM a   2$2 T!WW\222 RA R R R   r+cHtjdt|S)NzXfile() is deprecated and will be removed in a future version. Use handle_file() instead.)rrrr)rns r(rlrlSs) Mb  ' ''r+parameters_infolist[ParameterInfo] | Nonerr!rrc,Gddt}t|}||rtd|St|}||jgt||z zz}i}g}t |D]\}} d| vr'||| d<|| dn|d|| ddr)|||jkr| d||<|D]F\} } | |vr+|| |krtd | d | ||| <4td | d |j|vr0td || |j|S) NceZdZdZdS)!construct_args.._KeywordsNO_VALUEN)r@rArBryr$r+r( _Keywordsrx]sr+rzzzThis endpoint does not support key-word arguments Please click on 'view API' in the footer of the Gradio app to see usage.parameter_namez argument parameter_has_defaultFparameter_defaultz Parameter `zs` is already set as a positional argument. Please click on 'view API' in the footer of the Gradio app to see usage.zl` is not a valid key-word argument. Please click on 'view API' in the footer of the Gradio app to see usage.z)No value provided for required argument: ) r rrrryrr rPr TypeErrorr}) rtrrrz_argsnum_argskwarg_arg_mapping kwarg_namesr} param_infor=r s r(construct_argsrZs=D JJE  M  4yyH Y'(C,@,@8,KL LEK&77 ? ?z z ) )>C j)9: ;   z*:; < < < <   2522 3 3 3 NN2E : : ?e 222%>>*=>>E%Lllnn   U # # # %00[#[[[16',--PcPPP U"" f EKKPYPbDcDc8d f f    Lr+rhttpx.Responsec  |jdkr|dg}g}t|D]~\}}|dddkr_|ddurH|dd |}|d |d |d d|d t |d|rd|SdSdS)z If the request is a 422 error and the detail contains a validation error message, return the message. Otherwise, return None. idetail__type__rIvalidateis_validFr{ parameter_z- rmessagerz parameter(s) failed validation:rN)rrNrPrr r*rr)rrvalidation_messagesr} error_info param_names r(extract_validation_messagers5 #"-- !*6!2!2   E:z2..*<<NN:..%77'^^,<>R5>R>RSS #**FFFz~~i'D'DFF "" #)**LLL     299011 1! 2 2r+)rEr0)rEr:)rr0rEr:)rrrrrrrrrr0rr0rrrrrr:rrrEr)rrrrrrrrrr r4r0rrrr:rrrEr)rrrrrrrr:)rrrrrrrrrr0rr0rrrrrEr2) rrrrrr r4r0rrrEr2r)r5r0r6rrEr0)NN)rHr0rIrr6rrEr0)rXr0rEr)rcr0rEr)r5r0rirjrEr:)rUrr)r|r0)r,rr)rcr0rEr)r)rXr0rr5rEr0)r,rrrEr0)rr0rEr0)NNN)rcr0r5rr6rrr)rrr6r)r5rrrEr)Nr)rr0rIrrr5)rrrEr)rr)rrrEr0)r rrEr)r6rrrr7r8rEr)r6rrr>r7r8rEr)rArrEr:)rrrrrEr)rrrrIrEr:)rrrEr:)rnrr)rtrurr!rrrEr)rrrEr) __future__rrrvconcurrent.futuresrr1r'rNr^rPrJrer>rBr<r urllib.parserr collectionsrcollections.abcrr dataclassesrrr rr pathlibr threadingr typingr rrrrrrrr fsspec.asynrrrrgradio_client.data_classesrAPI_URL SSE_URL_V0SSE_DATA_URL_V0SSE_URL SSE_DATA_URLWS_URL UPLOAD_URL LOGIN_URL CONFIG_URL API_INFO_URLRAW_API_INFO_URLSPACE_FETCHER_URL RESET_URLr HEARTBEAT_URL CANCEL_URLSTATE_COMPONENT NO_APP_FILE CONFIG_ERROR BUILD_ERROR RUNTIME_ERRORPAUSEDINVALID_RUNTIMEcompilerr#rr/rTrrQrVrZr\r^r0r`rorrrrrrrrrrrrrrrrrGrWrbrhrqr{rrrrrrrrrrrrrrrFILE_DATA_FORMATSrrrr r r:r@rDrHrrCrZr]r_raSKIP_COMPONENTSrrrlrrr$r+r(rs """"""       ////////((((((((                       &&&&&&9888888         ( )F  ! *    <== $)      6 54 5 5 5  6 54 5 5 5        iu        "!##      9                i        I   ,,,,,C,,,"11111T111h          *  1 1 1 1 1 1 1  1   <,6 7 7    5555555 5  J J J J J J J  J&<<<<    FFFF$$$$N))))X....0CCCCL]]]]@'''^@D$$$$$*                 ''''---- 11111h3333 !!     F     !8 K K K K         CCCC*-R0???? KAKAKAKA\ppppf(0FFFF$(QQQQNNNN$ Q Q Q Q"     ((((0000f222222r+