o ٷi@sddlmZddlZddlZddlZddlZddlZddlZddl 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,dd l-m.Z.erdd l/m0Z0d Z1dZ2dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAe,jBe,jCe,jDe,jEe,jFgZGGddde#ddZHdd!d"ZIeIZJGd#d$d$eKZLGd%d&d&eKZMGd'd(d(eKZNGd)d*d*eKZOGd+d,d,ePeZQGd-d.d.eZReGd/d0d0ZSeGd1d2d2ZTeGd3d4d4ZUe"d5eTeUBZVd6d7ZWeGd8d9d9ZXeGd:d;d;ZYdd=d>ZZdd@dAZ[ddBdCZ\ dddKdLZ]ddZd[Z^ddadbZ_ddcddZ`ddedfZaddhdiZbdjdkZcdddodpZd dddsdtZeddvdwZfddydzZgdd}d~ZhdddZidddZjdddZkddddZldddZmddddZndddZo   ddddZpddddZqdddZr  ddddZsdddZtGdddeuZvdddZwgdZxexdZydddZzdddZ{dddZ|dddZ}dddZ~ddd„ZdddńZdddDŽZdddɄZddd˄Zddd̈́ZhdΣZdddфZdddӄZdddۄZddd߄ZdS() annotationsN)Callable Coroutine) dataclassfield)datetime)Enum)Path)Lock) TYPE_CHECKINGAnyLiteralNewType TypedDictUnionget_args get_originget_type_hints) SpaceStage)ClientConnection) 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}cancelstatec@s^eZdZUded<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__r2r2G/home/ubuntu/.local/lib/python3.10/site-packages/gradio_client/utils.pyrGs  rF)totalreturnrcCsHzttdd}t|}|dd}|WSty#YdSw)Nz package.jsonutf-8version) pkgutilget_datar.decodestripjsonloadsget Exception)package_json_data package_datar7r2r2r3get_package_versionTs   rCc@eZdZdZdS)TooManyRequestsErrorz.Raised when the API returns a 429 status code.Nr.r/r0__doc__r2r2r2r3rEcrEc@rD) QueueErrorzMRaised when the queue is full or there is an issue adding a job to the queue.NrFr2r2r2r3rIirHrIc@rD)InvalidAPIEndpointErrorz(Raised when the API endpoint is invalid.NrFr2r2r2r3rJorHrJc@rD)SpaceDuplicationErrorz:Raised when something goes wrong with a Space Duplication.NrFr2r2r2r3rKurHrKc@sDeZdZdZdZdZdZdZdZdZ 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.r/r0rMrNrOrPrQrRrSr,rTrUserver_stoppedrVrWrXr2r2r2r3rL{srLc@sbeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d ZedddZdddZedddZdS)Statusz'Status codes presented to client users.STARTING JOINING_QUEUE QUEUE_FULLIN_QUEUE SENDING_DATA PROCESSING ITERATINGPROGRESSFINISHED CANCELLEDLOGstatusr5r#c Cs6tjtjtjtjtjtjtjtjtj tj g }| |S)z'Order of messages. Helpful for testing.) rZr[r\r]r^r_r`rbrarcrdindex)rforderr2r2r3orderings zStatus.orderingothercCs||||kSN)ri)selfrjr2r2r3__lt__sz Status.__lt__rrcCsXtjtjtjtjtjtjtjtj tj tj tj tj tjtjtjtjtjtjtjtji |S)zKMap the raw message from the backend to the status code presented to users.)rLrMrZr\rNr]rOr^rPr_rQr`rRrarSrcrTrbr,rerY)rr2r2r3 msg_to_statuss zStatus.msg_to_statusN)rfrZr5r#)rjrZ)rrr5rZ)r.r/r0rGr[r\r]r^r_r`rarbrcrdre staticmethodrirmrnr2r2r2r3rZs$  rZc@sDeZdZUded<ded<ded<ded<ded<edd dZdS) ProgressUnit int | Nonerglength str | Noneunit float | NonerTdescdatar*r5list[ProgressUnit]csfdd|DS)Nc s<g|]}|d|d|d|d|ddqS)rgrrrtrTrv)rgrrrtrTrvr?).0dclsr2r3 sz)ProgressUnit.from_msg..r2)r}rwr2r|r3from_msgs zProgressUnit.from_msgN)rwr*r5rx)r.r/r0r1 classmethodrr2r2r2r3rps rpc@sbeZdZUdZded<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.rZcoderqr$r'ruetaz bool | Noner)zdatetime | Nonetimezlist[ProgressUnit] | Noner+Nztuple[str, str] | Noner,rfzLiteral['status', 'output']type)r.r/r0rGr1r,rr2r2r2r3rs  rc@s:eZdZUdZded<ded<dZded<d Zded <d S) OutputUpdater list[Any]outputsr(r)r!zLiteral['output']rFfinalN)r.r/r0rGr1rrr2r2r2r3rs  rUpdatec CsttjddddtddS)N)rr$r'rr)rr+)rrZr[rnowr2r2r2r3create_initial_status_updatesrc@s6eZdZUdZeedZded<eedZ ded<dS) JobStatuszpThe job status. Keeps track of the latest status update and intermediate outputs (not yet implements). default_factoryr latest_statusrrN) r.r/r0rGrrrr1listrr2r2r2r3rs rc@sveZdZUdZded<ded<ded<ded <d Zd ed <d Zded<d Zd ed<d Zded<e e j dZ ded<d S) CommunicatorzKHelper class to help communicate between the worker thread and main thread.r lockrjobzCallable[..., tuple]prediction_processorr reset_urlFr( should_cancelNrsr"thread_completedict[str, str] | Nonerequest_headersrzasyncio.Queue[Update]updates) r.r/r0rGr1rr"rrrasyncioQueuerr2r2r2r3r s     rr(cCst|tsdS|dS)zN Check if the given value is a string that looks like an HTTP(S) URL. F)zhttp://zhttps://) isinstancer startswith possible_urlr2r2r3is_http_url_likes  rrcCsddi}z7t(}tj||d}|jdkr&|j||djWdWS|jWdWS1s4wYWdStyEYdSw)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_coder? is_successr@)rrclient head_requestr2r2r3 probe_url&s  ( rcCstdt|o 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.)warningswarnrrrr2r2r3 is_valid_url5sr websocketrrw hash_datahelperCommunicator | Noner c s\d}i}|s*t|}|st|rh|jH|jrYt4IdH%}|j|j t |d}| tj ||ddIdHWdIdHn 1IdHsOwYtjWdn1scwYtdIdH|r|} t | }|r|jnd|v} tt|d|d|d d|d t|d | rt|dndd } |d idg} | r| jtjkrz|j| } Wnty}z |g} WYd}~nd}~ww|jj !| | |j_"Wdn1swY|ddkrt#d|ddkr|$|IdHn|ddkr"|$|IdH|ddk}|r|d S)NF)r=T)return_exceptionsg{Gz?r+rr'r$r)r&rr'r$r)rrr+r!rwrN Queue is full! Please try again.rMrPrS)%r create_taskrecvdonerrr AsyncClientpostrr=r>rgather concurrentfuturesCancelledErrorsleepresultrrZrnr?rrrprrrcrr@rrappendrrIsend)rrwrr completedresptaskhttprr has_progress status_updater!rer2r2r3get_pred_from_ws@sr (       4rr httpx.Clientdictsse_url sse_data_urlrdict[str, str]cookiesr ssl_verifyexecutor%concurrent.futures.ThreadPoolExecutordict[str, Any] | Nonec  Csd|_| t||||} | t|||||||| } tjj| | gtjjd\} } d|_t| dkr:t dt| d| D]}| SdSNF) return_whenTzDid not expect z tasks to be done.) rsubmitcheck_for_cancel stream_sse_v0rrwaitFIRST_COMPLETEDlen ValueErrorr)rrwrrrrrrrr future_cancel future_sser_futurer2r2r3get_pred_from_sse_v0s2      rpending_messages_per_eventdict[str, list[Message | None]]r"protocol'Literal['sse_v1', 'sse_v2', 'sse_v2.1']cCsd|_|t||||}|t||||} tjj|| gtjjd\} } d|_t| dkr6t dt| d| D]} | } | rB| | SdSr) rrrstream_sse_v1plusrrrrrr exceptionr)rrrrr"rrrrrrrrrr2r2r3get_pred_from_sse_v1pluss(      rcCs td|j|jr Wdn|jrtjWdn1s'wYq|jr>t j |j d|ji|||dtj)NT皙?r")r=rrverify) rrrrrrrrr"rrr)rrrrr2r2r3rs(   rcCsDz|jd||||d}|D]} | d} t| dkrq| drt| dd} | dtjtj fvr8q|j nd| v} t t | d| d | d d| d t| d | rdt| dndd } | didg} | r| jt jkrz|j| }Wnty}z |g}WYd}~nd}~ww|jj|| |j_Wdn1swY|jrtj| ddkrtd| ddkr| d}||_ |j!|d|i||||d}|"q| ddkr| dWdWSqt#d| Wdt#d1swYt#dtjjy!w)NGET)paramsrr rdata:rr+r'r$r)r&rr!rwrNrrPr")r=rrrSzUnexpected message: z*Did not receive process_completed message.)$stream iter_linesrstriprrr=r>rLr,rUrrrZrnr?rrrprrrcrr@rrrrrrrrrIr"rraise_for_statusr)rrwrrrrrrresponselinerrrr!rrr"reqr2r2r3rs               2 66r1Literal['sse_v1', 'sse_v2', 'sse_v2.1', 'sse_v3']c Csz:||}d} t|dkr|d}ntdq|dus"|jr'tj|jd}|dt j krF| d}| d} |rF| rF|| f}t t |d| d| dd| d t| d d |vrlt|d nd|d } | d i dg} |dt jkr|dvr|durt| }nt| D]\} } || }t|| }||| <|| | <q| r| jt jkrz|j| }Wnty}z |g}WYd}~nd}~ww|jj||jt || d dd| |j_!|j| Wdn1swY|dt j"kr/||=| d dst#|d $} n|d } |jt | d| d dd|d WS|dt j%kr;t&dq tjjyFw)NTrrrr,r-r'r$r)r&r+)rr'r$r)rrr+r,r!rw)sse_v2zsse_v2.1sse_v3)rr))rrr)zServer stopped.)'rpoprrrrrrrrLr,r?rrZrnrrrprrRr enumerate apply_diffrrcrr@rrrr put_nowaitrrrSritemsrYr)rrr"rpending_messagespending_responses_for_diffsr log_messager,r-rr!ivalue prev_output new_outputrrr2r2r3r$s            -  JrcCs4t|}dd}|D] \}}}|||||}q |S)NcSst|dkr|dkr |S|dkr||Std||}tt|dD]}|||}q%|d}|dkr<|||<|S|dkrJ|||7<|S|dkrct|tr]|t|||S|||<|S|dkrxt|trs|t|=|S||=|Std |) NrreplacerzUnsupported action: radddeletezUnknown action: )rrrangerrinsertr#)targetpathactionrcurrentr last_pathr2r2r3 apply_edits:      zapply_diff..apply_edit)copydeepcopy)objdiffrrrrr2r2r3r|s !r file_pathdirrscCsNt|pttd}|jddd|t|j}t||t | S)NTexist_okparents) r tempfile gettempdirsecrets token_hexmkdirnameshutilcopy2rresolve)rr directorydestr2r2r3create_tmp_copy_of_files   r+url_pathhf_tokenc Cs|dur tj|dd|rdd|ini}t|pttd}|jddd|t|j}t j d||dd -}| t |d }| D]}||qHWdn1sZwYWdn1siwYt|S) z0Kept for backwards compatibility for 3.x spaces.NTr AuthorizationBearer rrr)rfollow_redirectswb)osmakedirsr r r!r"r#r$r%rrropeniter_rawwriterr() r,r-rrr)rrfchunkr2r2r3download_tmp_copy_of_files&    r:filenamecCs<|drdSt|d}|dur|dddd}|S)Nz.vttztext/vttrzx-wavwavzx-flacflac)endswith mimetypes guess_typer )r;mimetyper2r2r3 get_mimetypes rBencodingcCs^|dd}t|d}|dkrdS|durdSt|}|dur-|dr-|dd}|S)Nz audio/wavz audio/x-wavrz audio/flacr=.r)r r?r@guess_extensionr)rCr extensionr2r2r3 get_extensions   rG file_types list[str]cCs~t|}|D]6}|dkrdS|dr-|d}t|jd}||kr,dSq|dur<||dr<dSqdS)NfileTrD/F)rBrlstriplowerr suffix)rrH mime_type file_typefile_extr2r2r3 is_valid_files rRr8 str | PathcCspt|d)}t|}t|d}tt|}d|dur|ndd| WdS1s1wYdS)Nrbr6rr8;base64,)r5base64 b64encodereadrrB)r8rJencoded_string base64_strrAr2r2r3encode_file_to_base64s   $r[urlcCsLt|}|t|j}t|d}t|}d|dur|ndd|S)Nr6rr8rU)rr?rrVrWcontentrrB)r\rrYrZrAr2r2r3encode_url_to_base64s   r^rcCs t|}t|r t|St|Srk)rrr^r[)rr2r2r3encode_url_or_file_to_base64sr_ccsrt}|r dd|ini}tjd||d}|D] }||7}|VqWdn1s/wY|VdS)Nr/r0rr) bytearrayrr iter_bytes)r\r-arrrrrwr2r2r3download_byte_stream s  rdtuple[bytes, str | None]cCs&t|}|ddd}t||fS)N,rr )rGrsplitrV b64decode)rCrFrwr2r2r3decode_base64_to_binarysri max_bytesr#cCstj|\}}ddd|D}||}t|}||krA||krAt|dkr- |S|dd}||}t|}||ks$|S)aV Strips invalid characters from a filename and ensures it does not exceed the maximum byte length Invalid characters are any characters that are not alphanumeric or one of the following: . _ - , The filename may include an extension (in which case it is preserved exactly as is), or could be just a name without an extension. r8cS g|] }|s |dvr|qS)z._-, isalnumrzcharr2r2r3r~# z5strip_invalid_filename_characters..rNr )r3rsplitextjoinrencode)r;rkr%ext filename_lenr2r2r3!strip_invalid_filename_characterss    rw original_namecCs ddd|DddS)zECleans up a Python parameter name to make the API info more readable.r8cSrl)z _rmror2r2r3r~3rqz,sanitize_parameter_names.. r)rsr rM)rxr2r2r3sanitize_parameter_names0srzstr | Path | Noneprefixc Cst|pttd}|jdddt|\}}|durA|durAt|j}|}d|vrA|d|d}||ddd}|durIt |}|durVtj d||d}n tj d|d||d }| || |S) NrTrrDrrF)r r|r)r r|rNr) r r r!r"r#r$rir%rgrwNamedTemporaryFiler7flush) rCrrr|r)rwrFr;file_objr2r2r3decode_base64_to_file9s0   rjsnstr | dict | listcCsT|dur tj|ddtjdd|dd}t|trt|}t||| |S)NTr.Fz.jsonzw+)r rNrmode) r3r4r r}rrr=r>dumpr~)rrrr2r2r3dict_or_str_to_json_file\s   r dict | listcCs6t| }t|WdS1swYdSrk)r5r=load)rr8r2r2r3 file_to_jsonjs $r,space_idtimeout_in_secondsc Cshtjj|dtd}ztjd|dd|i|dWdStjy3}z tdt |d|d}~ww) N gradio_client)token 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__rrHTTPStatusErrorrK SPACE_URLformat)rr-rrrr2r2r3set_space_timeoutrs&  rfuncrr cOs"tjjtj|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)rargskwargsr2r2r3synchronize_asyncs" rc@s eZdZdS)APIInfoParseErrorN)r.r/r0r2r2r2r3rsrschemacCszd|vrdSd|vr dSd|vr|dS|drdS|dr"dS|dr)dS|dr0dSd|vr6iStd|) Nconstenumr$refoneOfanyOfallOfzCannot parse type for )r?r)rr2r2r3get_types"    r)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 cCst||d}|tdS)N$defsfilepath)_json_schema_to_python_typer?r CURRENT_FILE_DATA_FORMAT)rtype_r2r2r3json_schema_to_python_types rc sV|ikrdSt|}|ikrd|divrdSdS|dkr,t|dddS|dkr2d S|d kr>d |d d S|d krRd ddd|d Dd S|dkrXdS|dkr^dS|dkrddS|dkrjdS|dkr|dg}d|vrdfdd|dD}d|d Sd|vrdfdd|dD}d|d St|}d|d S|d krd!d"|d#i}fd$d|D}d%|vr|d%}t|tr|r|d&g7}n |d't|g7}d|}d(|d)S|d*vr d+fd,d||D}|S|d-kr$dfd.d/||D} d0| d }|Std1|)2z/Convert the json schema into a python type hintr r= descriptionz str | float | bool | list | dictrrKr nullNonerzLiteral[]rz, cSsg|] }dt|dqS)')r)rzvr2r2r3r~sz/_json_schema_to_python_type..integerr#stringrbooleanr(numberr%arrayr prefixItemscg|]}t|qSr2rrzrdefsr2r3r~ztuple[crr2rrrr2r3r~rzlist[objectcSs |drd|ddSdS)Nrz ()r8ry)rr2r2r3get_descs z-_json_schema_to_python_type..get_desc propertiescs4g|]\}}|dkr|dt||qS)r: r)rznrrrr2r3r~s additionalPropertieszstr, Anyzstr, zdict(r)rrz | crr2rrrr2r3r~ rrc3s|]}t|VqdSrkrrrr2r3 sz._json_schema_to_python_type..zAll[zCannot parse schema ) rr?rsplitrsrrr(r) rrrrelementspropsdesadditional_propertiesrvrwr2rr3rsz             r type_hintcCs"zt|WStyiYSwrk)_python_type_to_json_schemar@)rr2r2r3python_type_to_json_schemas   rcCs|tdur ddiS|turiS|turddiS|tur ddiS|tur(ddiS|tur0ddiS|tur9did S|turBd id S|turJdd iS|t usR|t urWd d d S|t us_|t urddddSt |}|turt|}t|dkr|d|diSdt|iS|tust|dr|jdkst|dkrt|}t|dkrtd|vrtdd|D}t|}dddi|giSddd|DiS|turt|}|sd id S|d}d t|d S|turt|}|sdd iSt|dkr|ddurd t|dd Sd dd|Dt|t|d S|t us|t ur6t|}|s*d d d S|d}d d t|d!S|tur]t|}|sGdid S|\}} |turTtd"dt| d }|St|rtt|trtd#d|D} d| iSt|rt|d$ri} g} t|} | D].\}}t|| |<t|d%r|jr| |qt|d&r|j|j s| |qd| d'}| r| |d(<|SiS))z,Convert a Python type hint to a JSON schema.Nrrrrrrr)rrr)rrT)r uniqueItemsbyte)rrrrrrr. UnionType|css |] }|tdur|VqdSrk)rrztr2r2r3rEsz._python_type_to_json_schema..rrcSg|]}t|qSr2rrr2r2r3r~Hz/_python_type_to_json_schema...cSrr2rrr2r2r3r~Xr)rrminItemsmaxItems)rrrz0JSON Schema only supports string keys in objectscSsg|]}|jqSr2)r)rzitemr2r2r3r~usr1 __total____dataclass_fields__)rrrequired)!rr rr#r%r(rrtupleset frozensetbytesr`rr rrrhasattrr.nextrrinspectisclass issubclassrrrrrrdefault)roriginliteral_valuestypes other_typerr item_typekey_type value_type enum_valuesrrhints field_name field_typer2r2r3rs                       rjson_objis_rootCallable[..., bool]cCsz||r||St|tr"i}|D] \}}t|||||<q|St|ttfr;g}|D] }|t|||q-|S|S)zk Traverse a JSON object and apply a function to each element that satisfies the is_root condition. )rrrtraverserrrrrrnew_objkeyrrr2r2r3rs r'Callable[..., Coroutine[Any, Any, Any]]cs||r ||IdHSt|tr)i}|D]\}}t|||IdH||<q|St|ttfrEg}|D]}|t|||IdHq4|S|S)zq Traverse a JSON object and apply a async function to each element that satisfies the is_root condition. N)rrrasync_traverserrrrr2r2r3rs rapi_infocs&t||dtfddtDS)Nrc3s|]}|vVqdSrkr2)rzfile_data_formatinfor2r3rsz value_is_file..)rr?anyFILE_DATA_FORMATS)rr2rr3 value_is_filesrcCs&t|ttfot|ot|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)sr2r2r3 is_filepaths&r cCs t|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)rrrr{r2r2r3 is_file_objs r cCs<t|tod|vot|dtod|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"} } rmeta_typer8gradio.FileData)rrrr?r r2r2r3is_file_obj_with_metas  rcCst|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\)rrrr r2r2r3is_file_obj_with_urls r> boxrowtabformtabsgrouprcolumndatasetsidebartabitem accordioninterpretationfilepath_or_urlcCslt|}|ddid}t|ri||dd|dSt|r.i|dt|jiStd|d ) Nrr)rrrKr ) orig_namer\r zFile z; does not exist on local filesystem and is not a valid URL.)rrrr rr%r)rr rwr2r2r3 handle_files  r!cCstdt|S)NzXfile() is deprecated and will be removed in a future version. Use handle_file() instead.)rrr!)rr2r2r3rJsrJparameters_infolist[ParameterInfo] | Nonerrrrc Cs@Gdddt}t|}|dur|rtd|St|}||jgt||}i}g}t|D]2\}} d| vrF||| d<|| dn|d|| ddrb|||jkrb| d||<q0|D]$\} } | |vr|| |kr}t d | d | ||| <qgt d | d |j|vrt d || |j|S) Nc@rD)z!construct_args.._KeywordsNO_VALUEN)r.r/r0r$r2r2r2r3 _Keywordssr%zzThis 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: ) rrrrr$rrr?r TypeErrorrg) r"rrr%_argsnum_argskwarg_arg_mapping kwarg_namesrg param_inforrr2r2r3construct_argssJ      r/rhttpx.Responsec Cs|jdkrQ|dg}g}t|D]+\}}|dddkr>|ddur>|dd |}|d |d |d dq|d t|d|rSd|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__r8validateis_validFr& parameter_z- rmessagerz parameter(s) failed validation:rN)rr=r?rrrrrs)rr1validation_messagesrg error_info param_namer2r2r3extract_validation_messageIs$  r:)r5r)r5r()rrr5r(rk) rrrwrrrrrr5r )rrrwrrrrrrrrrrrrrrr(rrr5r)rrrrrrrrr"rrrrr(rrr5r)rrrrrrrr()rrrwrrrrrrrrrrrrrr5r ) rrrrr"rrrr5r )rrrrsr5r)NN)r,rr-rsrrsr5r)r;rr5rs)rCrr5rs)rrrHrIr5r()r8rS)r\r)rrS)rCrr5re)rj)r;rrkr#r5r)rxrr5r)NNN)rCrrrsrr{r|rs)rrrr{)rrSr5r)Nr)rrr-rsrr#)rrr5r )rr)rr r5r)rr r5r)rr rrrrr5r )rr rrrrr5r )rrr5r()rrS)r"r#rrrrr5r)rr0r5rs) __future__rrrVconcurrent.futuresrrrr=r?r3r9r"r&r rrcollections.abcrr dataclassesrrrrrpathlibr threadingr typingr r r rrrrrr fsspec.asynrrrrwebsockets.asyncio.clientrgradio_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_RUNTIMErrCrr@rErIrJrKrrLrZrprrrrrrrrrrrrrrrrr+r:rBrGrRr[r^r_rdrirwrzrrrrrrrrrrrrrrrrrr r rrSKIP_COMPONENTSr!rJr/r:r2r2r2r3s     ,      4      ? '  FX /       #       M  s       3