5pj%p%SrSSKJr SSKrSSKrSSKJrJr SSKJ r SSK J r J r SSK JrJr SSKrSS KJrJr SS KJrJrJrJr SS KJrJrJrJrJrJrJ r SS K!J"r"J#r#J$r$J%r%J&r& SS K'J(r( S/r)\("S5r*\+"1Sk5r,S\-S'\+"1Sk5r.S\-S'\\\4r/S\-S'\0\1\ 4r2\3\4\1\14r5\\1\1\6-\7-\8-4S-r9"SS5r:SSjr;g)uLow-level client for the ModelScope OpenAPI v1 surface. This module is *internal*: it is consumed by :mod:`modelscope_hub.api` to build the ergonomic public façade. Direct use is discouraged and not subject to the SDK's stability guarantees. Design goals ------------ * A single :meth:`OpenAPIClient._request` chokepoint owns transport concerns — URL composition, authentication injection, retry/back-off, error decoding and ``data`` envelope unwrapping. * Each of the 25 OpenAPI endpoints maps to exactly one method, named after the resource it manipulates and grouped by section comments. * Filter-style query parameters (``filter.task=...`` etc.) are accepted as a flat ``filters`` mapping and serialised transparently. ) annotationsN)IterableMapping)Path)AnyBinaryIO)urljoinurlsplit) HubConfigget_default_config)API_CONNECT_TIMEOUTAPI_MAX_RETRIES API_TIMEOUTOPENAPI_PREFIX)AuthenticationErrorInvalidParameter NetworkErrorRateLimitErrorRequestTimeoutError ServerErrorraise_for_status)CreateSkillPayloadCreateStudioPayloadDeployMcpServerPayloadUpdateSkillSettingsPayloadUpdateStudioSettingsPayload) get_logger OpenAPIClientopenapi>GETPUTHEADDELETEOPTIONSzfrozenset[str]_IDEMPOTENT_METHODS>/stop/deploy /undeploy_RETRYABLE_POST_PATHSztuple[type[BaseException], ...]_RETRYABLE_EXCc \rSrSrSrS;SSSS.SSjrS?SjrS@SSSSSSS S SS . SAS jjjr \ SBS j5r SCS jr SDSjr SS.SESjjrSFSjrSGSjr\SHSj5r\S;SISjj5rS@SSSSSSS S SS . SASjjjr\SJSj5rSKSjrSSSSSSS.SLSjjrSMSjrSSSSSSS.SLSjjrSMSjrSSSSSSS .SNS!jjrSSSSS".SOS#jjrSPS$jrSQS%jrSRS&jrSSS'jr SMS(jr!S;STS)jjr"SMS*jr#SS+SSSS,.SUS-jjr$SMS.jr%SVS/jr&SVS0jr'SWS1jr(SXS2jr)SSSSSS3.SYS4jjr*SKS5jr+SS6.SZS7jjr,S;S[S8jjr-S\S9jr.S:r/g)]rGaLThin, typed wrapper around the public ``/openapi/v1`` endpoints. Parameters ---------- config: Optional :class:`HubConfig` instance. When omitted the process-wide default returned by :func:`get_default_config` is used. session: Optional pre-configured :class:`requests.Session`. Useful for tests and for sharing a connection pool across multiple clients. timeout: Per-request read timeout in seconds. When omitted, uses ``(API_CONNECT_TIMEOUT, API_TIMEOUT)`` as ``(connect, read)`` tuple. max_retries: Maximum number of retry attempts for transient failures. N)sessiontimeout max_retriesc,U=(d [5UlU=(d [R"5UlUb [ U5O[ [ 5[ [54UlUb[U5Ul g[[5Ul gN) r _configrequestsSession_sessionfloatrr_timeoutintr _max_retries)selfconfigr.r/r0s S/var/www/html/pdf-tiff/venv/lib/python3.13/site-packages/modelscope_hub/_openapi.py__init__OpenAPIClient.__init__Ysq5!3!5 58#3#3#5 %1E'N>Q8RTYZeTf7g 1<0GC ,SQ`Mac8URR5 g)z$Release the underlying HTTP session.N)r6closer;s r=rBOpenAPIClient.closeks r@cU$r2rCs r= __enter__OpenAPIClient.__enter__os r@c$UR5 gr2)rB)r;_excs r=__exit__OpenAPIClient.__exit__rs  r@T urlparams json_bodydatafilesheaders require_tokenunwrapr/c 4URUUUUUUUUU U U S9 $)a0Execute an HTTP request. When *url* is provided the request targets that absolute URL directly (useful for endpoints outside ``/openapi/v1``, signed OSS URLs, etc.). Otherwise the request is routed through ``self._url(path)``. When *unwrap* is ``False`` the raw :class:`requests.Response` is returned. rM_request) r;methodpathrNrOrPrQrRrSrTrUr/s r=requestOpenAPIClient.requestxs;.}}  '  r@cpURR=(d SRS5[S3$)z;Fully-qualified OpenAPI base URL, including trailing slash./)r3endpointrstriprrCs r=base_urlOpenAPIClient.base_urls1<<((.B66s;<^ ``pre-lfs.modelscope.cn``, ``modelscope.cn`` -> ``lfs.modelscope.cn``). Those hosts DO require our credentials, so they are trusted here too. r^FT.r Nzlfs.zpre-lfs.) r hostnamelower ValueErrorr3r`splitlenjoin)r; target_url target_host endpoint_hostlabelsbases r=_same_host_as_endpoint$OpenAPIClient._same_host_as_endpoints #J/88>BEEGK"$,,"7"7"=2>GGM2TTV -  '$$S)'*6{a'7sxxqr #]dV}.?@@@  s,C CCcU(d/$/nUR5H/up#UbUS:XaMURSU3[U545 M1 U$)z:Serialise a flat mapping into ``filter.key=value`` tuples.r^zfilter.)itemsappendstr)filtersflatkeyvalues r=_flatten_filtersOpenAPIClient._flatten_filterssSI!--/JC}  KK73%#e*5 6* r@cd^/nU(axUR5HdumnUcM [U[[[45(aUR U4SjU55 MHUR T[U545 Mf UR [RU55 U=(d S$)zHCombine plain query params with filter-prefixed ones, dropping ``None``.Nc3F># UHocMT[U54v M g7fr2)r).0itemrs r= .OpenAPIClient._merge_params..s!Yut"23D "2us!!) r isinstancelisttuplesetextendrrrr)rOrmergedrrs @r= _merge_paramsOpenAPIClient._merge_paramss ! $lln U=edE3%788MM!Yu!YYMM3E "34 -  m44W=>~r@c 4^U=(d URT5n URU 5(a)[URU S95n UR 5nO0n 0nU(aU R U5 UR 5n[SUR5nSn[SUS-5Hn[RSX5 URRUU UUUUU UU bU O URS9 n[RSXUR5 URS:aD[RSUU UURUR (aUR SS OS 5 [#U5 U (dUs $UR%US S 9s $ UceUe![&a nUnSnAOSnAff=f![(R*an[-S U35nSnAO\SnAf[(R.an[1SU35nSnAO2SnAf[(R2an[1SU35nSnAOSnAff=f[5U[65=(d> U[8;=(d. US:H=(a" T=(a [;U4Sj[<55nUU:dU(d GM [?USS5nUb [AU5nO*[CSUS- -S5[DRF"SS5-n[RSUU UUU5 [HRJ"U5 GMl)aIExecute an HTTP request and return the unwrapped ``data`` payload. The method centralises authentication, retries on transient errors, and decoding of the standard ``{"success": ..., "data": ...}`` envelope. When *url* is given, it is used as-is (absolute URL). Otherwise the final URL is derived from *path* via :meth:`_url`. rpr Nz%s %s) rYrNrOjsonrQrRrScookiesr/z %s %s -> %siz1Request failed: %s %s params=%s status=%s body=%sir^T)rUzRequest timed out: zConnection error: zRequest failed: POSTc3F># UHnTRU5v M g7fr2)endswith)rprZs r=r)OpenAPIClient._request..Us ;lVkQRDMM!>M.L###M&#"H#'## L.1DSE/JK++ D'*.> EmmoGZ66N W 6? " W 6? " E+18## Dx}} D EsA**B BBc&URSS5$)u;``GET /users/me`` — fetch the authenticated user profile.r!z /users/merWrCs r=get_current_userOpenAPIClient.get_current_users}}UK00r@r )searchownersort page_number page_sizercXE-S:a[SXE-S35eURUUUUUS.U5nURSSUSS9$) u``GET /models`` — list models with pagination and filters. Supported filter keys: ``task``, ``library``, ``model_type``, ``custom_tag``, ``license``, ``deploy``. -page_number * page_size must be <= 3000 (got ).rrrrrr!z/modelsFrOrTrrrXr;rrrrrrrOs r= list_modelsOpenAPIClient.list_modelssl  "T )"%RS^SjRkkm#no o## *&     }}UIfE}RRr@c0URSSUSU3SS9$)uA``GET /models/{owner}/{repo_name}`` — fetch a model's metadata.r!z/models/r_FrprWr;r repo_names r= get_modelOpenAPIClient.get_models%}}UhugQyk$BRW}XXr@cXE-S:a[SXE-S35eURUUUUUS.U5nURSSUSS9$) uH``GET /datasets`` — list datasets. Filter keys: ``task``, ``license``.rrrrr!z /datasetsFrrrs r= list_datasetsOpenAPIClient.list_datasetssl  "T )"%RS^SjRkkm#no o## *&     }}UKe}TTr@c0URSSUSU3SS9$)uE``GET /datasets/{owner}/{repo_name}`` — fetch a dataset's metadata.r!z /datasets/r_FrprWrs r= get_datasetOpenAPIClient.get_datasets%}}Ujq $DTY}ZZr@) path_in_reporepo_id repo_typerevisioncommit_message extra_fieldsc/nUbURSSU445 UbURSSU445 UbURSSU445 U(aURSSU445 U(aURSSU445 U(a<UR5H(upU cM URU S[U 5445 M* Sn [U[[45(a=[ U5n U R S5n URSU R U S 445 OURSS US 445 URS S US 9U bU R5 $$!U bU R5 ff=f)u3``POST /files/upload`` — upload a single file (≤ 5 MiB). When called with ``repo_id`` / ``path_in_repo`` / ``repo_type``, the file is committed to the given repository. When called with only ``file``, a generic upload is performed and the response contains the file ID (used by skill creation, etc.). NrZrrrrrbfilezapplication/octet-streamz upload.binrz /files/upload)rR) rrrrropennamerXrB) r;rrrrrrrformrropened file_paths r= upload_fileOpenAPIClient.upload_filesn$')  # KK$ !56 7   KKT7O4 5  KKtY&78 9  KKdH%56 7  KK)D.+AB C *002 = S4U"4563 #' $d ,, J "- Vinnf>X%YZ[ VlD:T%UVW===E! "v! "s A>EE2)rrrrcX#-S:a[SX#-S35eURUUUS.U5nURSSUSS9$) ut``GET /skills`` — list skills. Filter keys: ``developer``, ``category``, ``license``, ``custom_tag``, ``owner``. rrrrrrr!/skillsFrr)r;rrrrrOs r= list_skillsOpenAPIClient.list_skillssf  "T )"%RS^SjRkkm#no o## *&    }}UIfE}RRr@c6URSS[U5S9$)u(``POST /skills`` — create a new skill.rrrPrXrr;rs r= create_skillOpenAPIClient.create_skills}}VY$w-}HHr@c*URSSU3SS9$)u-``GET /skills/{id}`` — fetch a skill by id.r!/skills/FrprW)r;skill_ids r= get_skillOpenAPIClient.get_skills}}Uhxj$9}OOr@cDURSSUSUS3[U5S9$)uJ``PATCH /skills/{owner}/{skill_name}/settings`` — update skill settings.PATCHr r_ /settingsrr)r;r skill_namesettingss r=update_skill_settings#OpenAPIClient.update_skill_settings"s6}} ugQzl) 48n  r@c6URSS[U5S9$)u0``POST /studios`` — create a new Studio space.rz/studiosrrrs r= create_studioOpenAPIClient.create_studio2s}}VZ4=}IIr@c2URSSUSU35$)u?``GET /studios/{owner}/{repo_name}`` — fetch Studio metadata.r! /studios/r_rWrs r= get_studioOpenAPIClient.get_studio6s }}Uiwa {$CDDr@cZURSSUSUS3U(a [U5S9$SS9$)uF``POST /studios/{owner}/{repo_name}/deploy`` — trigger a deployment.rrr_r(Nrr)r;rrrs r= deploy_studioOpenAPIClient.deploy_studio:sL}} wa {' 2'.d7m  59  r@c2URSSUSUS3SS9$)uE``POST /studios/{owner}/{repo_name}/stop`` — stop a running Studio.rrr_r'NrrWrs r= stop_studioOpenAPIClient.stop_studioGs'}}Vyq 5%IUY}ZZr@dpage_numrkeywordstart_timestamp end_timestampc dURUUUUUS.5n URSSUSUSU3U S9$)uH``GET /studios/{owner}/{repo_name}/logs/{log_type}`` — paginated logs.r%r!rr_z/logs/)rOrrX) r;rrlog_typer&rr'r(r)rOs r=get_studio_logsOpenAPIClient.get_studio_logsKs\##$&"#2!.   }} wa {& ;  r@c4URSSUSUS35$)uI``GET /studios/{owner}/{repo_name}/secrets`` — list configured secrets.r!rr_/secretsrWrs r=list_studio_secrets!OpenAPIClient.list_studio_secretsgs"}}Uiwa {($KLLr@c6URSSUSUS3X4S.S9$)uC``POST /studios/{owner}/{repo_name}/secrets`` — add a new secret.rrr_r0rrrrWr;rrrrs r=add_studio_secretOpenAPIClient.add_studio_secretks3}} wa {( 3!2  r@c6URSSUSUS3X4S.S9$)uN``PUT /studios/{owner}/{repo_name}/secrets`` — overwrite an existing secret.r"rr_r0r4rrWr5s r=update_studio_secret"OpenAPIClient.update_studio_secretss3}} wa {( 3!2  r@c6URSSUSUS3SU0S9$)uK``DELETE /studios/{owner}/{repo_name}/secrets`` — remove a secret by key.r$rr_r0rrrW)r;rrrs r=delete_studio_secret"OpenAPIClient.delete_studio_secret{s4}} wa {( 3cl  r@cDURSSUSUS3[U5S9$)uK``PATCH /studios/{owner}/{repo_name}/settings`` — update Studio settings.rrr_rrr)r;rrrs r=update_studio_settings$OpenAPIClient.update_studio_settingss6}} wa {) 48n  r@)rrrfilterextracX#-S:a[SX#-S35eUUUS.nU(a[U5US'U(aURU5 UR5VVs0sH upxUcM Xx_M nnnUR SSUSS 9$s snnf) u``PUT /mcp/servers`` — discover MCP servers (JSON body, not query). Parameters ---------- filter : dict, optional Nested filter object. Supported keys: ``category``, ``is_hosted``. r$z??r@)get_operational_urlcRURSU05nURSSU3USS9$)uC``GET /mcp/servers/{id}`` — fetch a single MCP server's manifest.rLr! /mcp/servers/Frr+)r; server_idrLrOs r=get_mcp_serverOpenAPIClient.get_mcp_servers:##%:rBrGrKr[propertyrbrfrnrsrxr staticmethodrrrXrrrrrrrrr rrrrrr"r-r1r6r9r<r?rGrJrPrVrY__static_attributes__rFr@r=rrGs&$( b,0 $"& b  b) b  b  b  b$# 9= $ ,0" $# # #  # 7 # # # # *# # # #  # POO8 6;4DA:   ( (o 9= $ ,0" $ooo  o 7 oooo*oooo ob(1" SS S  S  SSS S:Y" UU U  U  UUU U2[$(" $#%)15.$.! .  .  ..#./. .l" SS S  S  S S2IP      A    JE-1      *    ["&*$(         $ "   8M         B    &"+/*.YY Y  Y ) Y(Y Y@@,0 ee) e  eFJ  C    Mr@c<[[[U555$r2)rsortedr)keyss r= _coerce_keysrts D " ##r@)rsz Iterable[str]r]ztuple[str, ...])rs"# - *1XX%   Y '00[&\^\)22S(T~T3/  CH~5c?# #sSy5(4// 04 7L ML Mb$r@