o An0j@sVddlmZddlZddlZddlZddlZddlZddlZddl 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/d0d0ZSeGd1d2d2ZTd3d4ZUeGd5d6d6ZVeGd7d8d8ZWdd:d;ZXdd=d>ZYdd?d@ZZ dddHdIZ[ddWdXZ\dd^d_Z]dd`daZ^ddbdcZ_ddedfZ`dgdhZadddldmZb dddpdqZcddsdtZdddvdwZeddzd{Zfdd~dZgdddZhdddZiddddZjdddZkddddZldddZm   ddddZnddddZodddZp  ddddZqdddZrGdddesZtdddZugdZvevdZwdddZxdddZydddZzdddZ{dddZ|dddZ}ddd„Z~dddĄZdddƄZdddȄZdddʄZhdˣZddd΄ZdddЄZddd؄ZdS)) annotationsN)Callable Coroutine) dataclassfield)datetime)Enum)Path)Lock) TYPE_CHECKINGAnyLiteralOptional TypedDictUnionget_args get_originget_type_hints) SpaceStage)WebSocketCommonProtocol) ParameterInfoz api/predict/z queue/joinz queue/dataZuploadloginconfigzinfo?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__r1r1Z/home/wildlama/miniconda3/envs/lam_a2e/lib/python3.10/site-packages/gradio_client/utils.pyrGs  rF)totalreturnrcCsHzttdd}t|}|dd}|WSty#YdSw)Nz package.jsonutf-8version) pkgutilget_datar-decodestripjsonloadsget Exception)Zpackage_json_data package_datar6r1r1r2get_package_versionTs   rAc@eZdZdZdS)TooManyRequestsErrorz.Raised when the API returns a 429 status code.Nr-r.r/__doc__r1r1r1r2rCcrCc@rB) QueueErrorzMRaised when the queue is full or there is an issue adding a job to the queue.NrDr1r1r1r2rGirFrGc@rB)InvalidAPIEndpointErrorz(Raised when the API endpoint is invalid.NrDr1r1r1r2rHorFrHc@rB)SpaceDuplicationErrorz:Raised when something goes wrong with a Space Duplication.NrDr1r1r1r2rIurFrIc@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.r/rKrLrMrNrOrPrQr+rRrSserver_stoppedrTrUrVr1r1r1r2rJ{srJc@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 CANCELLEDLOGstatusr4r"c Cs6tjtjtjtjtjtjtjtjtj tj g }| |S)z'Order of messages. Helpful for testing.) rXrYrZr[r\r]r^r`r_rarbindex)rdorderr1r1r2orderings zStatus.orderingothercCs||||kSN)rg)selfrhr1r1r2__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.)rJrKrXrZrLr[rMr\rNr]rOr^rPr_rQrarRr`r+rcrW)rr1r1r2 msg_to_statuss zStatus.msg_to_statusN)rdrXr4r")rhrX)rrr4rX)r-r.r/rErYrZr[r\r]r^r_r`rarbrc staticmethodrgrkrlr1r1r1r2rXs$  rXc@sDeZdZUded<ded<ded<ded<ded<edd dZdS) ProgressUnitz Optional[int]relengthz Optional[str]unitzOptional[float]rRdescdatar)r4list[ProgressUnit]csfdd|DS)Nc s<g|]}|d|d|d|d|ddqS)rerorprRrq)rerorprRrqr>).0dclsr1r2 sz)ProgressUnit.from_msg..r1)rxrrr1rwr2from_msgs zProgressUnit.from_msgN)rrr)r4rs)r-r.r/r0 classmethodrzr1r1r1r2rns rnc@sVeZdZUdZded<ded<ded<ded<d ed <d ed <d ed<dZded<dS) StatusUpdatezIUpdate message sent from the worker thread to the Job on the main thread.rXcodez int | Noner#r&z float | Noneetaz bool | Noner(zdatetime | Nonetimezlist[ProgressUnit] | Noner*Nztuple[str, str] | Noner+)r-r.r/rEr0r+r1r1r1r2r|s r|c CsttjddddtddS)N)r}r#r&r~r(rr*)r|rXrYrnowr1r1r1r2create_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_statusz list[Any]outputsN) r-r.r/rErrrr0listrr1r1r1r2rs rc@sVeZdZUdZded<ded<ded<ded <d Zd ed <d Zded<d Zd ed<d S) CommunicatorzKHelper class to help communicate between the worker thread and main thread.r lockrjobzCallable[..., tuple]prediction_processorr reset_urlFr' should_cancelN str | Noner!thread_complete)r-r.r/rEr0rr!rr1r1r1r2rs   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_urlr1r1r2is_http_url_like s  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)httpxZClienthead status_coder>Z is_successr?)rrclientZ head_requestr1r1r2 probe_urls  ( 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.)warningswarnrrrr1r1r2 is_valid_url%sr websocketrrr hash_datahelperCommunicator | Nonerc 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)Zreturn_exceptionsg{Gz?r*rr&r#r(r%r}r&r#r(rr~r*r rrrL Queue is full! Please try again.rKrNrQ)%asyncioZ create_taskrecvdonerrrZ AsyncClientpostrr<r=rZgather concurrentfuturesCancelledErrorsleepresultr|rXrlr>rrrnrzr}rarr?rrappendrrGsend)rrrrr completedresptaskhttprr has_progress status_updater rer1r1r2get_pred_from_ws0sr (       4rr httpx.Clientdictsse_url sse_data_urlrdict[str, str]cookiesdict[str, str] | None ssl_verifyexecutor%concurrent.futures.ThreadPoolExecutordict[str, Any] | Nonec  Csd|_| t||||} | t|||||||| } tjj| | gtjjd\} } d|_t| dkr:t dt| d| D]}| SdSNF)Z return_whenTzDid not expect z tasks to be done.) rsubmitcheck_for_cancel stream_sse_v0rrwaitFIRST_COMPLETEDlen ValueErrorr)rrrrrrrrrrr future_cancel future_sser_futurer1r1r2get_pred_from_sse_v0os2      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!rrrrrrrrrr1r1r2get_pred_from_sse_v1pluss(      rcCs td|j|jr Wdn|jrtjWdn1s'wYq|jr>t j |j d|ji|||dtj)NT皙?r!)r<rrverify) rrrrrrrrr!rrr)rrrrr1r1r2rs(   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 rrrLrrNr!)r<rrrQzUnexpected message: z*Did not receive process_completed message.)$stream iter_linesrstriprrr<r=rJr+rSrr|rXrlr>rrrnrzr}rarr?rrrrrrrrrGr!rraise_for_statusr)rrrrrrrrrresponselinerrrr rrr!reqr1r1r2rs               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|| |j_Wdn1swY|dt jkr||=|d WS|dt j krt!dq tjjyw)NTrrrr+r,r&r#r(r%r*)r}r&r#r(rr~r*r+r rr)Zsse_v2zsse_v2.1Zsse_v3zServer stopped.)"rpoprrrrrrrrJr+r>r|rXrlrrrnrzrPr enumerate apply_diffr}rarr?rrrrrQrWr)rrr!rZpending_messagesZpending_responses_for_diffsrZ log_messager+r,rr ivalueZ prev_outputZ new_outputrrr1r1r2rsr             ) 9rcCs4t|}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")targetpathactionrcurrentrZ last_pathr1r1r2 apply_edit^s:      zapply_diff..apply_edit)copydeepcopy)objdiffrrrrr1r1r2r[s !r file_pathdirrcCsNt|pttd}|jddd|t|j}t||t | S)NTexist_okparents) r tempfile gettempdirsecrets token_hexmkdirnameshutilcopy2rresolve)rr directorydestr1r1r2create_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)rZfollow_redirectswb)osmakedirsr rrrrrrrrropenZiter_rawwriterr) r r rrr rrfchunkr1r1r2download_tmp_copy_of_files&    rfilenamecCs<|drdSt|d}|dur|dddd}|S)Nz.vttztext/vttrzx-wavZwavzx-flacflac)endswith mimetypes guess_typer)rmimetyper1r1r2 get_mimetypes rencodingcCs^|dd}t|d}|dkrdS|durdSt|}|dur-|dr-|dd}|S)Nz audio/wavz audio/x-wavrz audio/flacr.r)rrrguess_extensionr)r type extensionr1r1r2 get_extensions   r% file_types list[str]cCs~t|}|D]6}|dkrdS|dr-|d}t|jd}||kr,dSq|dur<||dr<dSqdS)NfileTr!/F)rrlstriplowerr suffix)rr&Z mime_type file_typeZfile_extr1r1r2 is_valid_files r.r str | PathcCspt|d)}t|}t|d}tt|}d|dur|ndd| WdS1s1wYdS)Nrbr5rr7;base64,)rbase64 b64encodereadrr)rr(encoded_string base64_strrr1r1r2encode_file_to_base64s   $r7urlcCsLt|}|t|j}t|d}t|}d|dur|ndd|S)Nr5rr7r1)rr>rr2r3contentrr)r8rr5r6rr1r1r2encode_url_to_base64s   r:rcCs t|}t|r t|St|Sri)rrr:r7)rr1r1r2encode_url_or_file_to_base64sr;ccsrt}|r dd|ini}tjd||d}|D] }||7}|VqWdn1s/wY|VdS)Nrrrr) bytearrayrrZ iter_bytes)r8r Zarrrrrrr1r1r2download_byte_streams  r>tuple[bytes, str | None]cCs&t|}|ddd}t||fS)N,rr)r%rsplitr2 b64decode)r r$rrr1r1r2decode_base64_to_binarysrC max_bytesr"cCstj|\}}ddd|D}||}t|}||krA||krAt|dkr- |S|dd}||}t|}||ks$|S)aT 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. r7cS g|] }|s |dvr|qS)z._- isalnumrucharr1r1r2ry z5strip_invalid_filename_characters..rNr)rrsplitextjoinrencode)rrErextZ filename_lenr1r1r2!strip_invalid_filename_characterss    rP original_namecCs ddd|DddS)zECleans up a Python parameter name to make the API info more readable.r7cSrF)z _rGrIr1r1r2ryrKz,sanitize_parameter_names.. r)rMrr+)rQr1r1r2sanitize_parameter_namessrSstr | Path | Noneprefixc Cst|pttd}|jdddt|\}}|durA|durAt|j}|}d|vrA|d|d}||ddd}|durIt |}|durVtj d||d}n tj d|d||d }| || |S) NrTrr!rrF)rrUr)rrUr,r) r rrrrrrCrrerPNamedTemporaryFilerflush) r rrrUr rrr$rfile_objr1r1r2decode_base64_to_files0   rYjsnstr | dict | listcCsT|dur tj|ddtjdd|dd}t|trt|}t||| |S)NTrFz.jsonzw+)rr,rmode) rrrrVrrr<r=dumprW)rZrrXr1r1r2dict_or_str_to_json_file;s   r^ dict | listcCs6t| }t|WdS1swYdSri)rr<load)rrr1r1r2 file_to_jsonIs $ra,space_idtimeout_in_secondsc Cshtjj|dtd}ztjd|dd|i|dWdStjy3}z tdt |d|d}~ww) NZ gradio_client)tokenZ library_nameZlibrary_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_hubutilsZbuild_hf_headers __version__rrZHTTPStatusErrorrI SPACE_URLformat)rcr rdrrr1r1r2set_space_timeoutQs&  rlfuncrr 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: )fsspecZasynsyncZget_loop)rmargskwargsr1r1r2synchronize_asyncms" rrc@s eZdZdS)APIInfoParseErrorN)r-r.r/r1r1r1r2rs}srsschemacCszd|vrdSd|vr dSd|vr|dS|drdS|dr"dS|dr)dS|dr0dSd|vr6iStd|) Nconstenumr#$refoneOfanyOfallOfzCannot parse type for )r>rs)rtr1r1r2get_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]))rcCst||d}|tdS)N$defsfilepath)_json_schema_to_python_typer>rCURRENT_FILE_DATA_FORMAT)rttype_r1r1r2json_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 | dictrwr)rnullNoneruzLiteral[]rvz, cSsg|] }dt|dqS)')r)ruvr1r1r2rysz/_json_schema_to_python_type..integerr"stringrbooleanr'numberr$arrayitems prefixItemscg|]}t|qSr1r~rurdefsr1r2ryztuple[crr1rrrr1r2ryrzlist[objectcSs |drd|ddSdS)Nrz ()r7rt)rr1r1r2get_descs z-_json_schema_to_python_type..get_desc propertiescs4g|]\}}|dkr|dt||qS)r|z: r)runrrrr1r2rys additionalPropertieszstr, Anyzstr, zdict(r)rxryz | crr1rrrr1r2ryrrzc3s|]}t|VqdSrirrrr1r2 sz._json_schema_to_python_type..zAll[zCannot parse schema ) r{r>r~splitrMrrr'rs) rtrrrelementspropsZdesZadditional_propertiesrqrrr1rr2r~sz             r~ type_hintcCs"zt|WStyiYSwri)_python_type_to_json_schemar?)rr1r1r2python_type_to_json_schemas   rcCs`|tdur ddiS|turddiS|turddiS|tur"ddiS|tur*ddiSt|}|turHt|}t|dkrBd |d iSd t |iS|t usRt|d krt|}t|d krtd|vrt dd|D}t |}d|vr}|ddg|d<|Sddi|g|d<|Sddd|DiS|t urt|d }dt |dS|t urt|}ddd|Dt|t|dS|turt|\}}|turtddt |d}|St|r't|dr'i} g} t|} | D],\} } t | | | <t|dr|jr| | qt|dr|j| js| | qd| d}| r%| |d<|S|tur.iSdS) z,Convert a Python type hint to a JSON schema.Nr#rrrrrrrurrv|css |] }|tdur|VqdSri)r#rutr1r1r2rsz._python_type_to_json_schema..rxrycSg|]}t|qSr1rrr1r1r2ryz/_python_type_to_json_schema..r)r#rcSrr1rrr1r1r2ry$r)r#rZminItemsZmaxItemsz0JSON Schema only supports string keys in objectsr)r#rr0 __total____dataclass_fields__)r#rrequired)r#rr"r$r'rr rrrrnextrtuplerrinspectisclasshasattrrrrrrdefaultr )roriginZliteral_valuestypesZ other_typertZ item_typeZkey_typeZ value_typerrhints field_nameZ field_typer1r1r2rs              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. )rrrtraverserrrrrmrZnew_objkeyritemr1r1r2rLs 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_traverserrrrr1r1r2r`s rapi_infocs&t||dtfddtDS)Nr|c3s|]}|vVqdSrir1)ruZfile_data_formatinfor1r2rzsz value_is_file..)r~r>anyFILE_DATA_FORMATS)rr1rr2 value_is_filexsrcCs&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)sr1r1r2 is_filepath}s&rcCs 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)rrrrvr1r1r2 is_file_objs rcCs<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_typer7gradio.FileData)rrrr>rr1r1r2is_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"} } r8)rrrrr1r1r2is_file_obj_with_urls r> tabZtabitemboxZsidebarZdatasetformZinterpretationZ accordiongrouptabscolumnrrowfilepath_or_urlcCslt|}|ddid}t|ri||dd|dSt|r.i|dt|jiStd|d ) Nrr)rrr)r) orig_namer8rzFile z; does not exist on local filesystem and is not a valid URL.)rrrr rrr)rrrrr1r1r2 handle_files  rcCstdt|S)NzXfile() is deprecated and will be removed in a future version. Use handle_file() instead.)rrr)rr1r1r2r(sr(parameters_infolist[ParameterInfo] | Nonerprrqrc Cs:Gdddt}t|}|dur|rtd|St|}||jgt||}i}g}t|D]/\}} d| vrF||| d<|| dn|d| ddr_|||jkr_| d||<q0|D]$\} } | |vr|| |krzt d | d | ||| <qdt d | d |j|vrt d || |j|S) Nc@rB)z!construct_args.._KeywordsNO_VALUEN)r-r.r/rr1r1r1r2 _KeywordssrzzThis endpoint does not support key-word arguments Please click on 'view API' in the footer of the Gradio app to see usage.Zparameter_namezargument {index}Zparameter_has_defaultFZparameter_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: ) rrrrrrrr>r TypeErrorre) rrprqr_argsnum_argsZkwarg_arg_mappingZ kwarg_namesreZ param_inforrr1r1r2construct_argssJ       r)r4r)r4r')rrr4r'ri) rrrrrrrrrr4r)rrrrrrrrrrrrrrrrrrr'rrr4r)rrrrrrrrr!rrrrr'rrr4r)rrrrrrrr')rrrrrrrrrrrrrrrrrr4r) rrrrr!rrrr4r)rrrrr4r)NN)r rr rrrr4r)rrr4r)r rr4r)rrr&r'r4r')rr/)r8r)rr/)r rr4r?)rD)rrrEr"r4r)rQrr4r)NNN)r rrrrrTrUr)rZr[rrT)rr/r4r_)Nrb)rcrr rrdr")rmrr4r )rtr)rtr r4r)rr r4r)rr rmrrrr4r )rr rmrrrr4r )rrr4r')rr/)rrrprrqrr4r) __future__rrr2concurrent.futuresrrrr<rrr8rrrrrcollections.abcrr dataclassesrrrrvrpathlibr threadingr typingr r r rrrrrrZ fsspec.asynrnrrgrZwebsockets.legacy.protocolrZgradio_client.data_classesrZAPI_URLZ SSE_URL_V0ZSSE_DATA_URL_V0ZSSE_URLZ SSE_DATA_URLZWS_URLZ UPLOAD_URLZ LOGIN_URLZ CONFIG_URLZ API_INFO_URLZRAW_API_INFO_URLZSPACE_FETCHER_URLZ RESET_URLrjZ HEARTBEAT_URLZ CANCEL_URLZSTATE_COMPONENTZ NO_APP_FILEZ CONFIG_ERRORZ BUILD_ERRORZ RUNTIME_ERRORZPAUSEDZINVALID_RUNTIMErrArir?rCrGrHrIrrJrXrnr|rrrrrrrrrrrrrr rrr%r.r7r:r;r>rCrPrSrYr^rarlrrrrsr{rrrr~rrrrrrrrrZSKIP_COMPONENTSrr(rr1r1r1r2s     ,      4      ? '  FG /       #       M  P