+jiddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlmZddlmZmZddlmZmZddlmZddlmZddlmZdd lm 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-ddl.Z.dd l.m/Z/e"rdd l0m1Z1d Z2dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAdZBe/jCe/jDe/jEe/jFe/jGgZHe jIdZJGdde&dZKdd"ZLeLZMGd#d$eNZOGd%d&eNZPGd'd(eNZQGd)d*eNZRGd+d,eSeZTGd-d.eZUeGd/d0ZVeGd1d2ZWeGd3d4ZXe%d5eWeXzZYd6ZZeGd7d8Z[eGd9d:Z\dd<Z]dd>Z^dd?Z_ddPZ`ddVZaddWZbddYZcdd[Zdd\Zeddd`Zf dddcZgddeZhddgZiddjZjddmZkddoZlddqZmdddrZnddtZodddxZpddzZq ddd}ZrdddZsddZt dddZuddZvGddewZxddZygdZzezdZ{ddZ|ddZ}ddZ~ddZddZddZddZddZdddZddZddZddZddZddZhdZddZddZddZddZdS)) 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`$!{}]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__W/home/wildlama/visual-decline/.venv/lib/python3.11/site-packages/gradio_client/utils.pyrrOsp HHHMMM IIIOOOOOOMMM HHHJJJJJr5rF)totalreturnr c tjtdd}t j|}|dd}|S#t$rYdSwxYw)Nz package.jsonutf-8version) pkgutilget_datar0decodestripjsonloadsget Exception)package_json_data package_datar;s r6get_package_versionrG\s  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.Nr0r1r2__doc__r4r5r6rIrIks88Dr5rIceZdZdZdS) QueueErrorzMRaised when the queue is full or there is an issue adding a job to the queue.NrJr4r5r6rMrMqsWWDr5rMceZdZdZdS)InvalidAPIEndpointErrorz(Raised when the API endpoint is invalid.NrJr4r5r6rOrOws22Dr5rOceZdZdZdS)SpaceDuplicationErrorz:Raised when something goes wrong with a Space Duplication.NrJr4r5r6rQrQ}sDDDr5rQcFeZdZdZdZdZdZdZdZdZ 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)r0r1r2rTrUrVrWrXrYrZr.r[r\server_stoppedr]r^r_r4r5r6rSrSsZIJJI%N-+ CHI3N)!L+r5rScveZdZdZdZdZdZdZdZdZ 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 CANCELLEDLOGstatusr8r%c  tjtjtjtjtjtjtjtjtj tj g }| |S)z'Order of messages. Helpful for testing.) rbrcrdrerfrgrhrjrirkrlindex)rnorders r6orderingzStatus.orderingsW O    O     O   O    {{6"""r5othercZ||||kSN)rr)selfrss r6__lt__z Status.__lt__s%}}T""T]]5%9%999r5r!r ctjtjtjtjtjtjtjtj tj tj tj tj tjtjtjtjtjtjtjtji |S)zKMap the raw message from the backend to the status code presented to users.)rSrTrbrdrUrerVrfrWrgrXrhrYrirZrkr[rjr.rmr`)r!s r6 msg_to_statuszStatus.msg_to_statuss  #V%9  $f&7  $fo  #V%8  (&*;  ,f.>  +V_  "FO  vz  (&/     r5N)rnrbr8r%)rsrb)r!r r8rb)r0r1r2rKrcrdrerfrgrhrirjrkrlrm staticmethodrrrwryr4r5r6rbrbs11H#MJH!LJIHHI C###\# ::::   \   r5rbcZeZdZUded<ded<ded<ded<ded<edd ZdS) ProgressUnit int | Nonerplength str | Noneunit float | Noner[descdatar,r8list[ProgressUnit]c fd|DS)Nc g|]q}|d|d|d|d|drS)rpr~rr[r)rpr~rr[rrC).0dclss r6 z)ProgressUnit.from_msg..s     CeeGnnuuXUU6]]z**UU6]]        r5r4)rrs` r6from_msgzProgressUnit.from_msgs0         r5N)rr,r8r)r0r1r2r3 classmethodrr4r5r6r|r|sp    [    r5r|cveZdZUdZded<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.rbcoder}r&r)retaz bool | Noner+zdatetime | Nonetimezlist[ProgressUnit] | Noner-Nztuple[str, str] | Noner.rnzLiteral['status', 'output']type)r0r1r2rKr3r.rr4r5r6rrsSSLLL,,,,"&C&&&&(0D000000r5rcDeZdZUdZded<ded<dZded<d Zded <d S) OutputUpdater list[Any]outputsr*r+r#zLiteral['output']rFfinalN)r0r1r2rKr3rrr4r5r6rrsOSSMMM&D&&&&Er5rUpdatec dttjddddtjdS)N)rr&r)rr+rr-)rrbrcr nowr4r5r6create_initial_status_updaters6  _   \^^   r5cXeZdZUdZeeZded<eeZ ded<dS) JobStatuszpThe job status. Keeps track of the latest status update and intermediate outputs (not yet implements). default_factoryr latest_statusrrN) r0r1r2rKrrrr3listrr4r5r6rrs[ #(%8T"U"U"UMUUUUt444G444444r5rceZdZUdZded<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_processorr reset_urlFr* should_cancelNrr$thread_completedict[str, str] | Nonerequest_headersrzasyncio.Queue[Update]updates) r0r1r2rKr3rr$rrrasyncioQueuerr4r5r6rrsUUJJJNNN....NNNMH!O!!!!-1O1111%*U7=%I%I%IGIIIIIIr5rr*cZt|tsdS|dS)zN Check if the given value is a string that looks like an HTTP(S) URL. F)zhttp://zhttps://) isinstancer startswith possible_urls r6is_http_url_liker%s0 lC ( (u  " "#: ; ;;r5rc(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_coderC is_successrD)rrclient head_requests r6 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 r6 is_valid_urlr=s; M H L ) ) Ei .E.EEr5r 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 r6get_pred_from_sse_v0rHs#FOO&'7JM   J %%  #&6&GD!"F 4yyA~~H3t99HHHIII}}r5pending_messages_per_event dict[str, deque[Message | None]]r$protocol'Literal['sse_v1', 'sse_v2', 'sse_v2.1']cd|_|t||||}|t||||} tj|| gtjj\} } d|_t| dkr tdt| d| D]/} | } | r| | cSdSr) rrrstream_sse_v1plusrrrrrr exceptionr)rrrrr$rrrrrrrrrs r6get_pred_from_sse_v1plusros#FOO&'7JM6#=xJ %%  #&6&GD!"F 4yyA~~H3t99HHHIII$$&&  O}} r5ct tjd|j5|jr dddn>|jrt j dddn #1swxYwYn|jr%tj |j d|ji|||t j)NT皙?r$)rArrverify) rsleeprrrrrCancelledErrorr$rpostr)rrrrs r6rrs& : 4 [ : :#  : : : : : : :% : (77999 : : : : : : : : : : : : : : : ::   fo.        + + - --s A$%A$$A(+A(r"c> |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:r!r-r)r&r+r()rr)r&r+rrr-r#rrUz Queue is full! Please try again.rWr$)rArrrZzUnexpected message: z*Did not receive process_completed message.)$stream iter_linesrstriprrrArBrSr.r\rrrbryrCr rr|rrrkrrDrrappendrrrrrrMr$rraise_for_statusr)rrrrrrrrresponselineresp has_progress status_updater#rer$reqs r6rrs"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} |dtjkrM|dvrI|t)| }n7t+| D]'\} } || }t-|| }||| <|| | <(| r| jtjkr |j| }n#t4$r }|g}Yd}~nd}~wwxYw|jj||jtA|| d d| |j_!|j| dddn #1swxYwY|dtj"kr||=| d ds(tG|d $} n|d } |jtA| d| d d|d S|dtj%krtMd#t jj$rwxYw)NTrrr!r.r/r)r&r+r(r-)rr)r&r+rrr-r.r#r)sse_v2zsse_v2.1sse_v3)rr+)rrr+zServer stopped.)'rpopleftrrrrrrrrSr.rCrrbryr rr|rrYr enumerate apply_diffrrkrrDrrrr put_nowaitrrrZritemsr`r)rrr$rpending_messagespending_responses_for_diffsr! log_messager.r/rr#ivalue prev_output new_outputrrs r6rrs; O5h?&*#H 4#$$q((&..00 4   {f4{ (77999, 9, 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(933HAu*Ea*HK)3K)G)GJ=G7:(2F1IIm0FOCC%!<!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) NrreplacerzUnsupported action: radddeletezUnknown action: )rrrangerrinsertr%)targetpathactionrcurrentr last_paths r6 apply_editzapply_diff..apply_editHsh t99>>"" 8##~% !@!@!@AAAs4yy1}%% ' 'Ad1g&GGH Y  !&GI   x   I   % '     u__'4(( +s9~~u5555%* "" x  '4(( 'C NN++I&&88899 9 r5)copydeepcopy)objdiffr#r rrs r6r r EsU -  CB $33ejdFE22 Jr5 file_pathdirrc8t|ptjtjdz }|dd|t|jz }tj||t| S)NTexist_okparents) r tempfile gettempdirsecrets token_hexmkdirnameshutilcopy2r resolve)r(r) directorydests r6create_tmp_copy_of_filer:ts~S1H/1122W5Fr5J5JJI OOT4O000 tI+ +D LD!!! t||~~  r5url_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 r+r,r)rfollow_redirectswb)osmakedirsr r/r0r1r2r3r4rrropeniter_rawwriter r7) r;r<r)rr8r(rfchunks r6download_tmp_copy_of_filerJ|s  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)rKfilename_lowermimetypes r6 get_mimetyperUs^^%%Nv&&zw''|#H--a0H##GU33;;HfMM Or5encodingc|dd}tj|d}|dkrdS|dStj|}||dr |dd}|S)Nz audio/wavz audio/x-wavrz audio/flacrN.r)rrQrRguess_extensionr)rVr extensions r6 get_extensionr[s ];;H   ) )! ,D |v t)$//I!5!5c!:!:abbM r5 file_types list[str]cxt|}|D]}|dkrdS|drj|d}t |jd}||krdS|||drdSdS)NfileTrX/F)rUrlstriprOr suffix)r(r\ mime_type file_typefile_exts r6 is_valid_filerfsY''I     44    $ $ !((--3355II-44S99??AAHH$$tt%  "y';';yOOO'L'L "44 5r5rH str | Pathct|d5}tj|}t |d}t t |}d||ndzdz|z cdddS#1swxYwYdS)Nrbr:rr<;base64,)rEbase64 b64encodereadr rU)rHr_encoded_string base64_strrTs r6encode_file_to_base64rps a  $)$))++6611 A'' #/xxR 9                     sA"BBBurlctj|}|tj|j}t |d}t|}d||ndzdz|zS)Nr:rr<rj)rrCrrkrlcontentr rU)rqrrnrorTs r6encode_url_to_base64rtso 9S>>D%dl33N^W--JC  Hx388. s*RRR$4<<>>RTT\\\\\r5 r)joinrrO)rs r6sanitize_parameter_namesrs? RR-RRRSS c   r5str | Path | NoneprefixcZt|ptjtjdz }|ddt |\}}|Y|Wt|j}|}d|vr=|d|d}||ddzd}|t|}|tj d||}ntj d|d|z| }| || |S) Nr+Tr,rXrrF)rrr))rrrbr)) r r/r0r1r2r3rr4rprNamedTemporaryFilerGflush) rVr(r)rr8rrZrKfile_objs r6decode_base64_to_filersC S1H/1122W5Fr5J5JJI OOT4O000-h77OD) ??' (??a(.."5"556F !4!4q!8!:!:;I 26::.Y   .?      NN4 NN Or5jsnstr | dict | listc |tj|dtjdd|d}t |t rt j|}t j||| |S)NTr>Fz.jsonzw+)rrbr)mode) rCrDr/rrr rArBdumpr)rr)rs r6dict_or_str_to_json_filer3s  C$''''*W#DH#sjooIc8 NN Or5 dict | listc|t|5}tj|cdddS#1swxYwYdSru)rErAload)r(rHs r6 file_to_jsonrAsz iAy||s 155,space_idtimeout_in_secondsctj|dt} t jd|dd|i|dS#tj$r1}tdt |d|d}~wwxYw) N gradio_client)r< library_namelibrary_versionz"https://huggingface.co/api/spaces/z /sleeptimeseconds)rArz>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__rrHTTPStatusErrorrQ SPACE_URLformat)rr<rrrs r6set_space_timeoutrIs #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 r6synchronize_asyncres7 ; FK0022D J4 J J J6 J JJr5ceZdZdS)APIInfoParseErrorN)r0r1r2r4r5r6rrusDr5rschemacd|vrdSd|vrdSd|vr|dS|drdS|drdS|drdS|drdSd|vriStd|) Nconstenumr$refoneOfanyOfallOfzCannot parse type for )rCr)rs r6get_typerys&w v 6  f~ F   Cv G   Cw G  Cw G  Cw v    A A ABBBr5)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]))rc~t||d}|tdS)N$defsfilepath)_json_schema_to_python_typerCrCURRENT_FILE_DATA_FORMAT)rtype_s r6json_schema_to_python_typers2 ' 70C0C D DE ==1: > >>r5c4 |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 hintrrA descriptionz str | float | bool | list | dictrr`rnullNonerzLiteral[]rz, c8g|]}dt|zdzS)')r )rvs r6rz/_json_schema_to_python_type..s'#O#O#O1C#a&&L3$6#O#O#Or5integerr%stringr booleanr*numberr'arrayr prefixItemsc0g|]}t|Sr4rrrdefss r6rz/_json_schema_to_python_type..s$TTT!,Q55TTTr5ztuple[c0g|]}t|Sr4rrs r6rz/_json_schema_to_python_type..s$UUU!,Q55UUUr5zlist[object propertiesrcb|drd|ddndS)Nrz ()r<r)rs r6get_descz-_json_schema_to_python_type..get_descs634553G3GO/m,,////R Or5cbg|]+\}}|dk |dt||,S)r: r)rnrrrs r6rz/_json_schema_to_python_type..sT   1G|| G G/488 G((1++ G G||r5additionalPropertieszstr, Anyzstr, zdict(r)rrz | c0g|]}t|Sr4rrs r6rz/_json_schema_to_python_type..s$WWWA6q$??WWWr5rc38K|]}t|VdSrurrs r6 z._json_schema_to_python_type..s.UU!4Q==UUUUUUr5zAll[zCannot parse schema ) rrCrsplitr_is_file_schemarrr*r) rrrrelementspropsdesadditional_propertiesrrrs ` @r6rrs ||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 ? ?@@@r5 type_hintcF t|S#t$ricYSwxYwru)_python_type_to_json_schemarD)rs r6python_type_to_json_schemars9*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)rrrrrrr0 UnionType|c3<K|]}|tdu|VdSru)rrts r6rz._python_type_to_json_schema..s2FFA!4::2E2Ea2E2E2E2EFFr5rrc,g|]}t|Sr4rrs r6rz/_python_type_to_json_schema.. s!HHHQ5a88HHHr5.c,g|]}t|Sr4rrs r6rz/_python_type_to_json_schema..0s!JJJq7::JJJr5)rrminItemsmaxItems)rrrz0JSON Schema only supports string keys in objectscg|] }|j Sr4)r)ritems r6rz/_python_type_to_json_schema..Ms888dtz888r5r3 __total____dataclass_fields__)rrrequired)!rrr r%r'r*rrtupleset frozensetbytesrxrrrrrhasattrr0nextrrinspectisclass issubclassr rrr rr default)roriginliteral_valuestypes other_typerr item_typekey_type value_type enum_valuesrr hints field_name field_types r6rrs"DJJC C!!C ""E!!D ""D "===D"---E  C9 11555EY)33 F333  " "F !),, ~  ! # #^A./ /^,,-- % FJ ' ' ,2O{,J,J v;;#  ## u::??tDzzU22FFFFFFFJ0<> , 5jAI , +++"*==  *!)F:  Ir5json_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 rr"rr#new_objkeyrr s r6r&r&hswx tH~~ Hd # # "..** : :JC#E499GCLL HtUm , , : :D NN8D$88 9 9 9 9r5'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 rr's r6r,r,|swx T(^^####### Hd # # "..** F FJC!/tW!E!EEEEEEEGCLL HtUm , , F FD NNdG!D!DDDDDDD E E E Er5api_infocJt||diS)Nr)_schema_contains_filerC)r-s r6 value_is_filer0s 8<<+D+D E EEr5rchd|vr-|ddd}||vr||S|S)z!Resolve a $ref to its definition.rr`r)rrrref_names r6 _resolve_refr4sC &>'',,R0 t  > ! Mr5 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).NrrrmetaF_typergradio.FileDatar)rCr4rr)rrrr7 meta_props type_schema meta_defaults r6rrs |zz'2&& JJ|R ( (E UfE11u f t , ,D,++J* ) w''+<<<88Ir**L,%%>((,=== 5r5ct|ts2t|trtfd|DSdSd|vr=|ddd}|vrt |SdSt |rdStfd|DS)zARecursively check if a JSON schema contains a file type anywhere.c38K|]}t|VdSru)r/)rr rs r6rz(_schema_contains_file..s.LLT,T488LLLLLLr5Frr`rTc3K|]9\}}|dk t|ttf't|V:dS)rN)rrrr/)rkrrs r6rz(_schema_contains_file..sU Aq <'',,R0 t  (h>> >uvt$$t LLNN  r5ct|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". )rr r existsis_file)ss r6 is_filepathrFsB a#t % % P$q''..*:*: PtAww?P?PPr5cjt|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)rrr rs r6 is_file_objrIs0 a   M6Q; M:ai3M3MMr5ct|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"} } rr7r8r<r9)rrr rCrHs r6is_file_obj_with_metarKsh 1d < aK < qy# & & < aK < fIMM'2 & &*; ; r5c^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"} } rq)rKrr rHs r6is_file_obj_with_urlrMs. ! # # P Pz!E(C7P7PPr5> boxrowtabformtabsgrouprcolumndatasetsidebartabitem accordioninterpretationfilepath_or_urlc0t|}|ddid}t|r$i||ddd|dSt|ri|d t|jiSt d |d ) Nr8r9)rr7r`r)maxsplitr) orig_namerqr]zFile z; does not exist on local filesystem and is not a valid URL.)r rrr rCr4r)rZrErs r6 handle_filer^s OA):; < %>r%B1MMMM a   2$2 T!WW\222 RA R R R   r5cHtjdt|S)NzXfile() is deprecated and will be removed in a future version. Use handle_file() instead.)rrr^)rZs r6r_r_s) Mb  ' ''r5parameters_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)r0r1r2rer4r5r6 _Keywordsrdsr5rfzzThis 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 rrrrer rrCr TypeErrorrp) r`rrrf_argsnum_argskwarg_arg_mapping kwarg_namesrp param_infor)rs r6construct_argsrps=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    Lr5rhttpx.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__r<validateis_validFrg parameter_z- rmessagerz parameter(s) failed validation:rN)rrArCr rrrr)rrsvalidation_messagesrp error_info param_names r6extract_validation_messager|Os5 #"-- !*6!2!2   E:z2..*<<NN:..%77'^^,<>R5>R>RSS #**FFFz~~i'D'DFF "" #)**LLL     299011 1! 2 2r5)r8r )r8r*)rr r8r*)rrrrrrrrrr rr rrrrrr*rrr8r)rrrrrrrrr$r rrrr*rrr8r)rrrrrrrr*)rrrrrrrrrr rr rrrrr8r") rrrrr$r rrr8r"ru)r(r r)rr8r )NN)r;r r<rr)rr8r )rKr r8r)rVr r8r)r(r r\r]r8r*)rHrg)rqr )rrg)rVr r8r})r)rKr rr%r8r )rr r8r )NNN)rVr r(rr)rrr)rrr)r)r(rgr8r)Nr)rr r<rrr%)rrr8r)rr)rrr8r )rrr8r)r"rrrr#r$r8r)r"rrr*r#r$r8r)r-rr8r*)rrrrr8r)rrrr5r8r*)rrr8r*)rZrg)r`rarr rrr8r)rrqr8r) __future__rrrkconcurrent.futuresrr$rrArQrCr=rer1r5r/rr 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_RUNTIMEcompilerrrGrrDrIrMrOrQr rSrbr|rrrrrrrrrrrrrrr r:rJrUr[rfrprtrvr|rrrrrrrrrrrFILE_DATA_FORMATSrrrrrr&r,r0r4rr/rFrIrKrMSKIP_COMPONENTSr^r_rpr|r4r5r6rs` """"""       ////////((((((((                       &&&&&&9888888         ( )F  ! *    <==      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@....0CCCCLUUUUp'''^@D$$$$$*                 ''''---- >!!     F     !8 K K K K         CCCC*-R0???? KAKAKAKA\ppppf(0FFFF$(QQQQNNNN$ Q Q Q Q"     ((((0000f222222r5