AF[i4ddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlmZmZddlmZmZddlmZddlmZddlmZddlmZdd lmZm 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,erdd l-m.Z.d Z/d Z0dZ1dZ2d Z3d Z4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?e,je,je,je,je,jgZEGdde#dZFdfdZGeGZHGdd eIZJGd!d"eIZKGd#d$eIZLGd%d&eIZMGd'd(eNeZOGd)d*eZPeGd+d,ZQeGd-d.ZReGd/d0ZSe"d1eReSzZTd2ZUeGd3d4ZVeGd5d6ZWdgd7ZXdhd8ZYdhd9ZZ did:Z[ djd;Z\ dkd<Z] dld=Z^ dmd>Z_d?Z`dndod@Za dp dqdAZbdrdBZcdsdCZddtdDZedudEZfdvdFZgdwdGZhdndvdHZidxdIZjdydzdJZkd{dKZl d| d}dLZmdnd~dMZnddNZo d ddOZpddPZqGdQdRerZsddSZtgdTZueudUZvddVZwddWZxddXZyddYZzddZZ{ dd[Z|dd\Z}dgd]Z~dgd^Zdgd_Zdgd`ZhdaZddbZddcZ dddZddeZy)) annotationsN)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}cancelstatecreZdZUded<ded<ded<ded<ded <ded <d ed <d ed<ded<ded<y)Messagestrmsgdict[str, Any]outputevent_idintrankfloatrank_eta queue_sizeboolsuccess list[dict] progress_dataloglevelN)__name__ __module__ __qualname____annotations__\/var/www/html/chatbot/moweb-chatbot/venv/lib/python3.12/site-packages/gradio_client/utils.pyrrFs6 H M IOO M H Jr4rF)totalc tjtdjdj }t j |}|jdd}|S#t$rYywxYw)Nz package.jsonutf-8version) pkgutilget_datar/decodestripjsonloadsget Exception)package_json_data package_datar9s r5get_package_versionrESsj   X~ 6 = =g F L L N zz"34 ""9b1 sAA"" A.-A.ceZdZdZy)TooManyRequestsErrorz.Raised when the API returns a 429 status code.Nr/r0r1__doc__r3r4r5rGrGbs8r4rGceZdZdZy) QueueErrorzMRaised when the queue is full or there is an issue adding a job to the queue.NrHr3r4r5rKrKhsWr4rKceZdZdZy)InvalidAPIEndpointErrorz(Raised when the API endpoint is invalid.NrHr3r4r5rMrMns2r4rMceZdZdZy)SpaceDuplicationErrorz:Raised when something goes wrong with a Space Duplication.NrHr3r4r5rOrOtsDr4rOcDeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZy) ServerMessage send_hash queue_full estimation send_dataprocess_startsprocess_generatingprocess_completedr-progress heartbeatzServer stopped unexpectedly.unexpected_error close_streamprocess_streamingN)r/r0r1rRrSrTrUrVrWrXr-rYrZserver_stoppedr[r\r]r3r4r5rQrQzsLIJJI%N-+ CHI3N)!L+r4rQcheZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zedd ZddZeddZy)Statusz'Status codes presented to client users.STARTING JOINING_QUEUE QUEUE_FULLIN_QUEUE SENDING_DATA PROCESSING ITERATINGPROGRESSFINISHED CANCELLEDLOGc Ttjtjtjtjtj tj tjtjtjtjg }|j|S)z'Order of messages. Helpful for testing.) r`rarbrcrdrerfrhrgrirjindex)statusorders r5orderingzStatus.orderingsn OO     OO       OO    OO     {{6""r4cH|j||j|kSN)rp)selfothers r5__lt__z Status.__lt__s}}T"T]]5%999r4cdtjtjtjtj tj tjtjtjtjtjtjtjtjtjtj tj"tj$tj&tj(tji |S)zKMap the raw message from the backend to the status code presented to users.)rQrRr`rbrSrcrTrdrUrerVrfrWrgrXrirYrhr-rkr^)r s r5 msg_to_statuszStatus.msg_to_statuss  # #V%9%9  $ $f&7&7  $ $foo  # #V%8%8  ( (&*;*;  , ,f.>.>  + +V__  " "FOO   vzz  ( (&//     r4N)rnr`returnr$)rtr`)r rrxr`)r/r0r1rIrarbrcrdrerfrgrhrirjrk staticmethodrprurwr3r4r5r`r`sg1H#MJH!LJIHHI C## :  r4r`cReZdZUded<ded<ded<ded<ded<ed d Zy ) ProgressUnit int | Nonermlength str | Noneunit float | NonerYdescc |Dcgc]Z}||jd|jd|jd|jd|jd\c}Scc}w)Nrmr}rrYr)rmr}rrYrrA)clsdatads r5from_msgzProgressUnit.from_msgsc   eeGnuuXUU6]z*UU6]     sAA'N)rr+rxzlist[ProgressUnit])r/r0r1r2 classmethodrr3r4r5r{r{s2        r4r{cteZdZUdZded<ded<ded<ded<d ed <d ed <d ed<dZded<dZded<y) StatusUpdateIUpdate message sent from the worker thread to the Job on the main thread.r`coder|r%r(retaz bool | Noner*zdatetime | Nonetimezlist[ProgressUnit] | Noner,Nztuple[str, str] | Noner-rnzLiteral['status', 'output']type)r/r0r1rIr2r-rr3r4r5rrsDS L    ,,"&C &(0D %0r4rcBeZdZUdZded<ded<dZded<d Zded <y ) OutputUpdater list[Any]outputsr)r*r"zLiteral['output']rFfinalN)r/r0r1rIr2rrr3r4r5rrs%S  M&D &E4r4rUpdatec fttjddddtjdS)N)rr%r(rr*rr,)rr`rarnowr3r4r5create_initial_status_updaters.  __   \\^ r4cJeZdZUdZeeZded<eeZ ded<y) JobStatuszpThe job status. Keeps track of the latest status update and intermediate outputs (not yet implements). default_factoryr latest_statusrrN) r/r0r1rIrrrr2listrr3r4r5rrs( #(8T"UM<Ut4GY4r4rceZdZUdZded<ded<ded<ded <d Zd ed <d Zded<d Zd ed<d Zded<e e jZ ded<y ) CommunicatorzKHelper class to help communicate between the worker thread and main thread.r lockrjobzCallable[..., tuple]prediction_processorr reset_urlFr) should_cancelNr~r#thread_completedict[str, str] | Nonerequest_headersrzasyncio.Queue[Update]updates) r/r0r1rIr2rr#rrrasyncioQueuerr3r4r5rrsWU J N..NM4Hj!OT!-1O*1%*7==%IG "Ir4rcFt|tsy|jdS)zN Check if the given value is a string that looks like an HTTP(S) URL. F)zhttp://zhttps://) isinstancer startswith possible_urls r5is_http_url_likers# lC (  " "#: ;;r4c.ddi} tj5}tj||}|jdk(r&|j ||j cdddS|j cdddS#1swYyxYw#t $rYywxYw)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_coderA is_successrB)rrclient head_requests r5 probe_urlr%sWXG \\^ +v ::lGDL''3.zz,z@KK + + **  + + + s;BAA< B' A<2 B<BBB BBc\tjdt|xr t|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 r5 is_valid_urlr4s- MM H L ) Ei .EEr4c d|_| jt||||} | jt|||||||| } tj j | | gtj j\} } d|_t| dk7rtdt| d| D]}|jcSyNF) return_whenTzDid not expect z tasks to be done.) rsubmitcheck_for_cancel stream_sse_v0 concurrentfutureswaitFIRST_COMPLETEDlen ValueErrorresult)rr hash_datahelpersse_url sse_data_urlrcookies ssl_verifyexecutor future_cancel future_ssedone_futures r5get_pred_from_sse_v0r?s#FOO&'7JM  J  %%  #&&66&GD!"F 4yA~?3t9+5GHII}}r4cd|_|jt||||}|jt||||} tj j || gtj j\} } d|_t| dk7rtdt| d| D]'} | j} | r| | jcSyr) rrrstream_sse_v1plusrrrrrr exceptionr)rrrpending_messages_per_eventr#protocolrrrrrrrrs r5get_pred_from_sse_v1plusrfs#FOO&'7JM6#=xJ  %%  #&&66&GD!"F 4yA~?3t9+5GHII$$& O}} r4c tjd|j5|jr dddn4|jrt j j dddl|jr0tj|jd|ji|||t j j#1swYdxYw)N皙?r#)r?rrverify) rsleeprrrrrCancelledErrorr#rpostr)rrrrs r5rrs  4 [[ :## : :%% ((7799& :    foo.      + + -- : :sC*CCc |jd||||5}|jD]H} | jd} t| dk(r$| j drt j | dd} | dtjtjfvrt|j5d| v} ttj| d| jd | jd d| jd tj | jd | rt"j%| dnd } | jdijdg} | rR| j&tj(k7r5 |j*| }|j.j0j3|| |j._ddd|j6rt8j:j=| ddk(r t?d| ddk(r9| d}||_ |jC|d|i||||}|jE#| ddk(s-| dccdddStGd|  dddtGd#t,$r}|g}Yd}~ d}~wwxYw#1swYxYw#1swYtGdxYw#t8j:j<$rwxYw)NGET)paramsrr rdata:r r,r(r%r*r')rr(r%r*rrr,r"rrSz Queue is full! Please try again.rUr#)r?rrrXzUnexpected message: z*Did not receive process_completed message.)$stream iter_linesrstriprrr?r@rQr-rZrrr`rwrArrr{rrrirrBrrappendrrrrrrKr#rraise_for_statusr)rrrrrrrrresponselineresp has_progress status_updater"rer#reqs r5rrs9 ]]    5 D  ++-. D{{4(t9>??7+::d12h/DE{}'8'8-:Q:Q&RR A'6$'> (4!'!5!5d5k!B'+xx '=!%&$!7$(HHY$7!) $ 4++7*?*?_@U*V!% ) "&(B!7!;!;FB!G!m&8&8FOO&K-)D)D)Df)M#JJ..55f=3@ 0)A*--(00??AAE{l2()KLLe 3#' #3*2$kk(",h!L$!L)!L$+$+ * ,,.e(;;#H~-g5 D5 Dj%';D6%BCC]. D5 DlEFF-$--*+-#AA5 DlEFF    , , syKBJ/)CJ#J 6J#BJ/J/ K&J/6K J J J#J J##J, (J//K4KK$c  ||}d} t|dkDr|jd}ntjd7| |jrt j j|j5d}|dtjk(r*|jd}|jd} |r| r|| f}ttj|d|jd|jdd|jd tj |jd d |vrt"j%|d nd| } |jd ijdg} |dtj&k(r@|dvr<| t)| }n.t+| D] \} } || }t-|| }||| <|| | <"| r| j.tj0k7rk |j2| }|j6j8j;||j<j?tA||jd d| |j6_!|j<j?| ddd|dtjDk(rs||=|jd dstG|d jI} n|d } |j<j?tA| d|jd d|d S|dtjJk(r tMd'#t4$r}|g}Yd}~Md}~wwxYw#1swYxYw#t j j$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.)'rpoprrrrrrrrQr-rArr`rwrrr{rrWr enumerate apply_diffrrirrBrrrr put_nowaitrrrXdictitemsr^r)rrr#rpending_messagespending_responses_for_diffsr log_messager-r.rr"ivalue prev_output new_outputrrs r5rrsJ O5h?&*##$q(&**1- 4 {f44 ((7799, 9" u:!2!22''%.CGGG,Eu'*El ,--c%j9"ww|4.GGI.! +&#-#/"7"7O8L"M# ! 2.2262>u:!A!AAhSG 3:6:6l3(1&(93HAu*Ea*HK)3K)GJ=G7:(2F1I 3 m00FOOC%!<!.apply_edit?s? t9>" 8#~% #7x!@AAs4y1}% 'Ad1g&G 'H Y !&GI   x  I % '  u_'4(s9~u5 &+ " x '4(C N+  I& /x89 9r4)copydeepcopy)objdiffrrrrs r5rr<sE -- CB $3edFE23 Jr4c$t|xstjtjdz }|j dd|t|j z }tj||t|jS)NTexist_okparents) r tempfile gettempdirsecrets token_hexmkdirnameshutilcopy2rresolve) file_pathdir directorydests r5create_tmp_copy_of_filer.ksmS1H//12W5F5Fr5JJI OOT4O0 tI++ +D LLD! t||~ r4cL|tj|d|rdd|zini}t|xstjt j dz }|jdd|t|jz }tjd||d 5}|jt|d 5}|jD]}|j| ddddddt|j!S#1swY*xYw#1swY.xYw) z0Kept for backwards compatibility for 3.x spaces.NTr AuthorizationBearer rrr)rfollow_redirectswb)osmakedirsr r!r"r#r$r%r&rrropeniter_rawwriterr)) url_pathtokenr+rr,r*rfchunks r5download_tmp_copy_of_filer>ss   C$'6; E 12GS1H//12W5F5Fr5JJI OOT4O0DN///I  x4  !!# )T " a!**,     y  " ##   s$ D='D%DD DD#c|jdry|jdrytj|d}|"|jddjdd }|S) Nz.vttztext/vttz.webpz image/webprzx-wavwavzx-flacflac)endswith mimetypes guess_typer )filenamemimetypes r5 get_mimetyperGsc !##H-a0H##GU3;;HfM Or4c|jdd}tj|d}|dk(ry|ytj|}||j dr|dd}|S)Nz audio/wavz audio/x-wavrz audio/flacrA.r)r rCrDguess_extensionr)encodingr extensions r5 get_extensionrMsp ];H    )! ,D | ))$/I!5!5c!:abM r4c<t|}|D]}|dk(ry|jdrY|jdj}t |j jdj}||k(sry|w|j|dsyy)NfileTrI/F)rGrlstriplowerr suffix)r* file_types mime_type file_typefile_exts r5 is_valid_filerXsY'I       $!((-335II--44S9??AHH$  "y';';ykO'L  r4ct|d5}tj|j}t |d}t t |}d||ndzdz|z cdddS#1swYyxYw)Nrbr8rr:;base64,)r7base64 b64encodereadrrG)r<rOencoded_string base64_strrFs r5encode_file_to_base64ras{ a  $))$))+61 A' #/xR 9      s AA**A3ctj|}|jtj|j }t |d}t|}d||ndzdz|zS)Nr8rr:r[)rrArr\r]contentrrG)urlrr_r`rFs r5encode_url_to_base64resc 99S>D%%dll3N^W-JC Hx38TT\RS c  Rs AAct|xstjtjdz }|j ddt |\}}|H|Ft|j}|}d|vr+|d|jd}||jddzd}| t|}|tjd||}ntjd|d|z| }|j||j|S) NrTrrIrrF)rprefixr+)rrrSr+) r r!r"r#r$r%rrr&rmr|NamedTemporaryFiler9flush) rKr*r+rr,rrLrEfile_objs r5decode_base64_to_filers  S1H//12W5F5Fr5JJI OOT4O0-h7OD) ?'' (?a(.."56F !4q!8!:;I 26:..Y ..?    NN4 NN Or4c|tj|dtjdd|d}t |t rt j|}t j|||j|S)NTr0Fz.jsonzw+)rrSr+mode) r5r6r!rrrr?r@dumpr)jsnr+rs r5dict_or_str_to_json_filersd  C$'**W#DH#sjjoIIc8 NN Or4cnt|5}tj|cdddS#1swYyxYwrr)r7r?load)r*r<s r5 file_to_jsonr,s+ iAyy|s+4c tjj|dt} t j d|dd|i|y#tj $r(}tdtj|d|d}~wwxYw) N gradio_client)r; library_namelibrary_versionz"https://huggingface.co/api/spaces/z /sleeptimeseconds)r?rz>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__rrHTTPStatusErrorrO SPACE_URLformat)space_idr;timeout_in_secondsrrs r5set_space_timeoutr4s ##44$#5G  0 * E/0  #LYM]M]^fMgLhiC C  sAB#A==Bctjjtjj|g|i|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)funcargskwargss r5synchronize_asyncrPs2 ;;  FKK002D J4 J6 JJr4c eZdZy)APIInfoParseErrorN)r/r0r1r3r4r5rr`sr4rcd|vryd|vryd|vr|dS|jdry|jdry|jdry|jdryd|vriStd|) Nconstenumr$refoneOfanyOfallOfzCannot parse type for )rAr)schemas r5get_typerds&  6 f~ F  G  G  G  v  "8 ABBr4)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 cdt||jd}|jtdS)N$defsfilepath)_json_schema_to_python_typerAr CURRENT_FILE_DATA_FORMAT)rtype_s r5json_schema_to_python_typers) ' 70C DE ==1: >>r4c |ik(ryt|}|ik(rd|jdivryy|dk(r$t|djddS|dk(ry |d k(r d |d d S|d k(r7d dj |d Dcgc]}dt |zdzc}zd zS|dk(ry|dk(ry|dk(ry|dk(ry|dk(r|jdg}d|vr2dj |dDcgc]}t|c}}d|d Sd|vr2dj |dDcgc]}t|c}}d|d St|}d|d S|dk(rd}|jdi}|j D cgc]#\} }| d k7r| d!t|||%} } }d"|vr1|d"} t| tr | r| d#gz } n| d$t| gz } dj | } d%| d&S|d'vr.d(j ||Dcgc]}t|c}} | S|d)k(r%dj fd*||D} d+| d } | Std,|cc}wcc}wcc}wcc}} wcc}w)-z/Convert the json schema into a python type hintr r? descriptionz str | float | bool | list | dictrrPr nullNonerzLiteral[]rz, 'integerr$stringrbooleanr)numberr&arrayr prefixItemsztuple[zlist[objectcR|jdrd|jddSdS)Nrz ()r:r)vs r5get_descz-_json_schema_to_python_type..get_descs+34553GRm,-Q/ OR Or4 propertiesr: additionalPropertieszstr, Anyzstr, zdict(r)rrz | rc36K|]}t|ywrr)r).0rdefss r5 z._json_schema_to_python_type..sU!4Q=UszAll[zCannot parse schema ) rrArsplitrurrrr)r)rrrrrrelementsrpropsndesadditional_propertiesrrs ` r5rrs" | V E { VZZ r2 25 &*4v0D0DS0I"0M+NPTUU & ' &/*!,, & v#O1C#a&L3$6#OP PSV V  )  (  )  (  '  7B' E !yy?D]?ST!,Q5THH:Q' ' f $yy?Em?TU!,Q5UHH:Q' '25$?H8*A& & (  P <,  1G|c/489(1+ G  "V +$*+A$B !/6;P |#78MtTUViinse1~ $ $zzPUWA6q$?WX ' yyUve}UUdV1~ "6vh ?@@q$PU V "XsI" ,I'"I,(I1I7c< t|S#t$ricYSwxYwrr)_python_type_to_json_schemarB) type_hints r5python_type_to_json_schemars&*955  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!|dk(rd|diSdt|iS|t"us)t%|dr|j&dk(st|dk(rft|}t!|dk(r2td|vr%t)d|D}t+|}dddi|giSd|Dcgc] }t+|c}iS|tur%t|}|sd id S|d}d t+|d S|turgt|}|sdd iSt!|dk(r|ddurd t+|dd Sd |Dcgc] }t+|c}t!|t!|dS|tus|tur&t|}|sd d d S|d}d d t+|dS|t ur:t|}|sdid S|\} } | tur t-ddt+| d }|St/j0|r-t3|t4r|D cgc]} | j6} } d| iSt/j0|rt%|dri} g}t9|}|j;D]u\}}t+|| |<t%|d r|j<s-|j?|?t%|d!r|j@|jBre|j?|wd| d"}|r||d#<|SiScc}wcc}wcc} w)$z,Convert a Python type hint to a JSON schema.Nrrrrrrr)rrr)rrT)r uniqueItemsbyte)rrrrrrr/ UnionType|c3<K|]}|tdus|ywrr)r)rts r5rz._python_type_to_json_schema..sFA!4:2EaFsrr.)rrminItemsmaxItems)rrrz0JSON Schema only supports string keys in objectsr2 __total____dataclass_fields__)rrrequired)"rr rr$r&r)rrtupleset frozensetbytesrirrrrrhasattrr/nextrrinspectisclass issubclassr rrrrrrdefault)roriginliteral_valuestypes other_typerrr item_typekey_type value_typeitem enum_valuesrrhints field_name field_types r5rrsDJC C!!C ""E!!D ""D "==D"--E  C9 155EY)3 F33  "F !), ~ ! #^A./ /^,-- % FJ 'FOO{,J v;# # u:?tDzU2FFFJ0 55jAII + ,#*= !)F:  IKI K:9sN$N0Nc||r||St|tr,i}|jD]\}}t|||||<|St|tt fr'g}|D]}|j t||| |S|S)zk Traverse a JSON object and apply a function to each element that satisfies the is_root condition. )rrrtraverserrrjson_objris_rootnew_objkeyrrs r5rrRsxH~ Hd #"..* :JC#E49GCL : HtUm , :D NN8D$8 9 :r4c\K||r||d{St|tr4i}|jD]\}}t|||d{||<|St|tt fr/g}|D]&}|j t|||d{(|S|S77T7w)zq Traverse a JSON object and apply a async function to each element that satisfies the is_root condition. N)rrrasync_traverserrrrs r5rrfsx(^## Hd #"..* FJC!/tW!EEGCL F HtUm , FD NNdG!DD E F$F Es4B,B&.sR,<4'Rs)rrAanyFILE_DATA_FORMATS)api_infor s @r5 value_is_filer~s* &xg1F GD R@QR RRr4ct|ttfxr4t|jxrt|j S)zp Check if the given value is a valid str or Path filepath on the local filesystem, e.g. "path/to/file". )rrr existsis_file)ss r5 is_filepathrs5 a#t % P$q'..*: PtAw?PPr4cXt|txrd|vxrt|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)rrrrs r5 is_file_objrs* a  M6Q; M:ai3MMr4ct|txr9d|vxr3t|dtxrd|vxr|djdddk(S)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"} } rmeta_typer:gradio.FileData)rrrrArs r5is_file_obj_with_metars_ 1d < aK < qy# & < aK < fIMM'2 &*; ; r4cNt|xrd|vxrt|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"} } rd)rrrrs r5is_file_obj_with_urlrs( ! # P Pz!E(C7PPr4> boxrowtabformtabsgrouprcolumndatasetsidebartabitem accordioninterpretationct|}|ddid}t|ri||jdd|dSt|j ri|dt|j iSt d|d ) Nrr)rrrPr ) orig_namerdr+zFile z; does not exist on local filesystem and is not a valid URL.)rrrr rr&r)filepath_or_urlrrs r5 handle_filer-s OA):; ._KeywordsNO_VALUEN)r/r0r1r2r3r4r5 _Keywordsr1sr4r3zzThis 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 rrrr2rrrAr TypeErrorrm) parameters_inforrr3_argsnum_argskwarg_arg_mapping kwarg_namesrm param_inforrs r5construct_argsr>sD JE M  4yH Y''(C,@8,KL LEK&7 ?z z )>C j)9: ;   z*:; <   5'2 3 NN2E :e 2 22%>>*=>E%L ?lln  U # # %0!#'Z[16',-cU#OP  U"7 EKKPYPbPbDc8d7e f   Lr4c |jdk(r|jjdg}g}t|D]k\}}|jdddk(s|jddus0|jdd |}|j d |d |jd dm|j d t |d|rdj|Syy)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_validFr4 parameter_z- rmessagerz parameter(s) failed validation:rN)rr?rArrrrru)rr@validation_messagesrm error_info param_names r5extract_validation_messagerI s #"- !*6!2  E:z2.*<NN:.%7'^^,< 5'>RS #** Bz~~i'D&EF   "" #)*++KL  9901 1 r4)rxr)rxr))rrrxr))r httpx.Clientrrrrrrrrrrrdict[str, str]rrrr)r%concurrent.futures.ThreadPoolExecutorrxdict[str, Any] | None)rrrrKrrrdict[str, list[Message | None]]r#rrz'Literal['sse_v1', 'sse_v2', 'sse_v2.1']rr)rrLrxrM)rrrrKrrrr))rrJrrrrrrrrrrrrKrrrxr!) rrrrNr#rrz1Literal['sse_v1', 'sse_v2', 'sse_v2.1', 'sse_v3']rxr!rr)r*rr+r~rxr)NN)r:rr;r~r+r~rxr)rErrxr~)rKrrxr~)r*rrTz list[str]rxr))r< str | Path)rdr)rrO)rKrrxztuple[bytes, str | None]))rErrxr$rxr)rrrxr)NNN)rKrr*r~r+str | Path | Nonerr~)rzstr | dict | listr+rQ)r*rOrxz dict | list)Ni,)rrr;r~rr$)rrrxr )rr)rr rxr)rr rxr)rr rrrCallable[..., bool]rxr )rr rz'Callable[..., Coroutine[Any, Any, Any]]rrRrxr )r rrxr))r,rO)r8zlist[ParameterInfo] | Nonerrrrrxr)rzhttpx.Responserxr~) __future__rrr\concurrent.futuresrrrr?rCr5r;r#r'r!rrcollections.abcrr dataclassesrrrrr pathlibr threadingr typingr r rrrrrrr 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_RUNTIMErrErrBrGrKrMrOrrQr`r{rrrrrrrrrrrrrrrr.r>rGrMrXrarergrmrrr|rrrrrrrrrr rrrrrrrrrrrrSKIP_COMPONENTSr-rOr>rIr3r4r5rss5"      /(    &8         ( )F  ! *    iu  "#  9    i  I ,C,"1T1h     *  1 1  1   <,6 7  55 5  J J  J&< F$ $ $$  $  $  $$#$$4$$N  #!@    6 4@. . .#. .0C C CC  C  C  CC#CCLU U ?UU@ U  Up'^@D$$$$2<$$*    '- (!!       F ! 8 K   C*-R0? JAZpf( 1! 0S QN$ Q"  (0/07<0FJ0 0f2r4