o wi[@sddlmZddlmZmZmZddlmZddlm Z m Z ddl m Z ddl Z ddlmZddlmZdd lmZdd lmZdd lmZdd lmZd dlmZd dlmZmZm Z m!Z!m"Z"m#Z#d dl$m%Z%m&Z&m'Z'd dl(m)Z)m*Z*erddl+m,Z,ddl-m.Z.GdddZ/dS)) annotations) TYPE_CHECKINGAnyLiteral) PositiveInt)Self assert_never)gqlN)tracked)nameof)Team)User)wandb_internal_pb2) RegistryData)AddOnlyArtifactTypesList)MemberId MemberKind MemberRole TeamMember UserMemberparse_member_ids) Visibility"fetch_org_entity_from_organizationprepare_artifact_types_input) CollectionsVersions)RetryingClient)RegistryFragmentc@seZdZUdZded< ded< dddeddZdfddZedgddZedgddZ edgddZ e j dhddZ edgddZ edgd d!Z edid#d$Zej djd%d$Zedkd'd(Zej dld)d(Zedmd+d,Zedgd-d.Zedgd/d0Zednd2d3Zedod5d6Zej dpd7d6Ze 8dqdrd>d?Ze 8dqdsdAdBZee  dtdudHdIZedvdJdKZedvdLdMZedvdNdOZdwdQdRZdxdTdUZdydWdXZdzd[d\Z dzd]d^Z!d{dbdcZ"dS)|Registryz"A single registry in the Registry.r_saved_currentNclientr organizationstrentitynameattrsRegistryFragment | NonecCsD||_|durtj|||d}||_|jdd|_dS||dS)N)r#r%r&Tdeep)r"rmodel_constructr model_copyr!_update_attributes)selfr"r#r%r&r'draftr0Y/home/ubuntu/.local/lib/python3.10/site-packages/wandb/apis/public/registries/registry.py__init__/szRegistry.__init__fragmentrreturnNonecCs"t|}||_|jdd|_dS)z3Update instance attributes from a GraphQL fragment.Tr)N)r from_fragmentr r,r!)r.r3savedr0r0r1r-Ds zRegistry._update_attributescC|jjS)z The unique ID for this registry.)r!idr.r0r0r1r9Jz Registry.idcCr8)zAFull name of the registry including the `wandb-registry-` prefix.)r! full_namer:r0r0r1r<Or;zRegistry.full_namecCr8)z:Name of the registry without the `wandb-registry-` prefix.r!r&r:r0r0r1r&Tr;z Registry.namevaluecCs ||j_dSNr=r.r>r0r0r1r&Y cCr8)z$Organization entity of the registry.)r!r%r:r0r0r1r%]r;zRegistry.entitycCr8)z"Organization name of the registry.)r!r#r:r0r0r1r#br;zRegistry.organization str | NonecCr8)zDescription of the registry.r! descriptionr:r0r0r1rDgr;zRegistry.descriptioncC ||j_dS)z$Set the description of the registry.NrCr@r0r0r1rDl boolcCr8)zReturn whether all artifact types are allowed in the registry. If `True`, artifacts of any type can be added. If `False`, artifacts are restricted to the types listed in `artifact_types`. r!allow_all_artifact_typesr:r0r0r1rIqsz!Registry.allow_all_artifact_typescCrE)z;Set whether all artifact types are allowed in the registry.NrHr@r0r0r1rIzrFrcCr8)a]Returns the artifact types allowed in the registry. If `allow_all_artifact_types` is `True` then `artifact_types` reflects the types previously saved or currently used in the registry. If `allow_all_artifact_types` is `False` then artifacts are restricted to the types in `artifact_types`. Note: Previously saved artifact types cannot be removed. Example: ```python import wandb registry = wandb.Api().create_registry() registry.artifact_types.append("model") registry.save() # once saved, the artifact type `model` cannot be removed registry.artifact_types.append("accidentally_added") registry.artifact_types.remove( "accidentally_added" ) # Types can only be removed if it has not been saved yet ``` )r!artifact_typesr:r0r0r1rJszRegistry.artifact_typescCr8)z+Timestamp of when the registry was created.)r! created_atr:r0r0r1rKr;zRegistry.created_atcCr8)z0Timestamp of when the registry was last updated.)r! updated_atr:r0r0r1rLr;zRegistry.updated_at list[str]cCs |j|jgSr?)r%r<r:r0r0r1pathrAz Registry.path%Literal['organization', 'restricted']cCs |jjjS)aVisibility of the registry. Returns: Literal["organization", "restricted"]: The visibility level. - "organization": Anyone in the organization can view this registry. You can edit their roles later from the settings in the UI. - "restricted": Only invited members via the UI can access this registry. Public sharing is disabled. )r! visibilityr&r:r0r0r1rPs zRegistry.visibilitycCrE)aSet the visibility of the registry. Args: value: The visibility level. Options are: - "organization": Anyone in the organization can view this registry. You can edit their roles later from the settings in the UI. - "restricted": Only invited members via the UI can access this registry. Public sharing is disabled. N)r!rPr@r0r0r1rPs dfilterdict[str, Any] | Noneper_pagerrcCst|j|jd|ji||dS)z2Returns the collections belonging to the registry.r&)r"r#registry_filtercollection_filterrT)rr"r#r<r.rRrTr0r0r1 collectionsszRegistry.collectionsrcCst|j|jd|jid||dS)z/Returns the versions belonging to the registry.r&N)r"r#rUrVartifact_filterrT)rr"r#r<rWr0r0r1versionsszRegistry.versionsrPrDrJlist[str] | Nonerc Csddlm}m}m} ddlm} m} d|d|d} t||} t|}||| | | |t |j | t |d}d| i}z|j||d }| |j}Wntya}zt| |d }~ww|rl|jrl|j}spt| |||| ||d S) a%Create a new registry. The registry name must be unique within the organization. This function should be called using `api.create_registry()` Args: client: The GraphQL client. organization: The name of the organization. name: The name of the registry (without the `wandb-registry-` prefix). visibility: The visibility level ('organization' or 'restricted'). description: An optional description for the registry. artifact_types: An optional list of allowed artifact types. Returns: Registry: The newly created Registry object. Raises: ValueError: If a registry with the same name already exists in the organization or if the creation fails. r)UPSERT_REGISTRY_GQLUpsertModelInputUpsertRegistry)REGISTRY_PREFIXvalidate_project_namezFailed to create registry  in organization .rD entity_namer&access$allow_all_artifact_types_in_registryrJinputvariable_valuesN)r#r%r&r')wandb.sdk.artifacts._generatedr\r]r^wandb.sdk.artifacts._validatorsr_r`rr r from_pythonr>r model_dumpexecutemodel_validate upsert_model Exception ValueErrorinsertedproject)clsr"r#r&rPrDrJr\r]r^r_r` failed_msg org_entitygql_op gql_inputgql_varsdataresulteregistry_projectr0r0r1creates>    zRegistry.createc Csddlm}m}d|jd|j}t|}d|ji}z|jj||d}| |j }Wnt y<}zt ||d}~ww|rB|j sFt |dS)z*Delete the registry. This is irreversible.r)DELETE_REGISTRY_GQLDeleteRegistryzFailed to delete registry rar9rhN)rjrrr&r#r r9r"rnro delete_modelrqrrsuccess) r.rrrvrxrzr{r|r}r0r0r1delete&s   zRegistry.deletec Csddlm}m}d|jd|jd}t|}|j|jd}z|jj ||d}| |}Wnt y>}zt ||d}~ww|j} rI| j } sMt ||| dS) z*Load registry attributes from the backend.r)FETCH_REGISTRY_GQL FetchRegistryzFailed to load registry rarb)r&r%rhN)rjrrr&r#r r<r%r"rnrorqrrrtr-) r.rrrvrxrzr{r|r}r%r~r0r0r1load7s"  z Registry.loadc Csddlm}m}m}m}m}m}ddlm}ddl m }||j t j s'td|jj} r;|jr;tdddd d d |jd |j} ||jj} ||jj} t|} ||j|j| |jjj|jt| d }d|i}z|j j| |d}| |j!}Wnt"y}zt| |d}~ww|r|j#rt$%d|jd |jd|r|j&}st| |'|| | krt|}||j| | d}d|i}|j j||d}| |j(}|r|j&}st| |j#rt$%d|jd|'|dSdS)z(Save registry attributes to the backend.r)RENAME_REGISTRY_GQLr\RenameProjectInputRenameRegistryr]r^)server_supports)r`zSaving the registry is not enabled on this wandb server version. Please upgrade your server version or contact support at support@wandb.com.zACannot update artifact types when `allows_all_artifact_types` is Tz . Set it to Fz first.zFailed to save registry rarcrgrhNzCreated registry z on save)rdold_project_namenew_project_namezCreated new registry ))rjrr\rrr]r^wandb.sdk.artifacts._gqlutilsrrkr`r"pb+INCLUDE_ARTIFACT_TYPES_IN_REGISTRY_CREATION RuntimeErrorrJr/rIrrr&r#r r<r!r rDr%rPr>rrmrnrorprqrswandbtermlogrtr-rename_project)r.rr\rrr]r^rr`new_artifact_typesrvrr upsert_op upsert_input upsert_varsr{r|r}r~ rename_op rename_input rename_varsr0r0r1saveNsv            z Registry.savelist[UserMember | TeamMember]cCsg||S)z?Returns the current members (users and teams) of this registry.) user_members team_membersr:r0r0r1membersszRegistry.memberslist[UserMember]cnddlm}m}t|}jjd}jj||d}||}|j }s-t dj fdd|j DS)z2Returns the current member users of this registry.r)REGISTRY_USER_MEMBERS_GQLRegistryUserMembersrtr%rhz*Failed to fetch user members for registry c s2g|]}ttj|jddhdd|jjdqS)Trole) exclude_noneexclude)r"r')userr)rr r"rmrr&.0mr:r0r1 s z)Registry.user_members..) rjrrr r<r%r"rnrortrrr&r)r.rrrxrzr{r|rtr0r:r1r    zRegistry.user_memberslist[TeamMember]cr)z2Returns the current member teams of this registry.r)REGISTRY_TEAM_MEMBERS_GQLRegistryTeamMembersrrhz*Failed to fetch team members for registry c s6g|]}ttj|jj|jjddd|jjdqS)T)r)r"r&r')teamr)rr r"rr&rmrrr:r0r1rs  z)Registry.team_members..) rjrrr r<r%r"rnrortrrr&r)r.rrrxrzr{r|rtr0r:r1rrzRegistry.team_membersr+User | UserMember | Team | TeamMember | strc Gddlm}m}m}|stdt|jdt|\}}t|}||||j d}d| i} |j j || d} | | j} | rB| jsJtd|j|S) afAdds users or teams to this registry. Args: members: The users or teams to add to the registry. Accepts `User` objects, `Team` objects, or their string IDs. Returns: This registry for further method chaining, if needed. Raises: TypeError: If no members are passed as arguments. ValueError: If unable to infer or parse the user or team IDs. Examples: ```python import wandb api = wandb.Api() # Fetch an existing registry registry = api.registry(name="my-registry", organization="my-org") user1 = api.user(username="some-user") user2 = api.user(username="other-user") registry.add_members(user1, user2) my_team = api.team(name="my-team") registry.add_members(my_team) ``` r)CREATE_REGISTRY_MEMBERS_GQLCreateProjectMembersInputCreateRegistryMembers$Must provide at least one member to rbuser_idsteam_ids project_idrgrhz"Failed to add members to registry )rjrrr TypeErrorr add_membersrr r9rmr"rnror|rrrr&) r.rrrrrrrxryrzr{r|r0r0r1r !    zRegistry.add_membersc Gr) ayRemoves users or teams from this registry. Args: members: The users or teams to remove from the registry. Accepts `User` objects, `Team` objects, or their string IDs. Returns: This registry for further method chaining, if needed. Raises: TypeError: If no members are passed as arguments. ValueError: If unable to infer or parse the user or team IDs. Examples: ```python import wandb api = wandb.Api() # Fetch an existing registry registry = api.registry(name="my-registry", organization="my-org") user1 = api.user(username="some-user") user2 = api.user(username="other-user") registry.remove_members(user1, user2) old_team = api.team(name="old-team") registry.remove_members(old_team) ``` r)DELETE_REGISTRY_MEMBERS_GQLDeleteProjectMembersInputDeleteRegistryMembersrrbrrgrhz'Failed to remove members from registry )rjrrrrr rrr r9rmr"rnror|rrrr&) r.rrrrrrrxryrzr{r|r0r0r1remove_membersrzRegistry.remove_membersmemberrMemberRole | strcCsddlm}m}m}m}m}m}t|} | j t j ur,t |} || |j|d} |} n| j t jurCt |} || |j|d} |} nt| j d| i} |jj| | d}| |j}|ra|jsotd|d|d |j|S) aUpdates the role of a member (user or team) within this registry. Args: member: The user or team to update the role of. Accepts a `User` object, `Team` object, or their string ID. role: The new role to assign to the member. May be one of: - "admin" - "member" - "viewer" - "restricted_viewer" (if supported by the W&B server) Returns: This registry for further method chaining, if needed. Raises: ValueError: If unable to infer the user or team ID. Examples: Make all users in the registry admins ```python import wandb api = wandb.Api() # Fetch an existing registry registry = api.registry(name="my-registry", organization="my-org") for member in registry.user_members(): registry.update_member(member.user, role="admin") ``` r)UPDATE_TEAM_REGISTRY_ROLE_GQLUPDATE_USER_REGISTRY_ROLE_GQLUpdateProjectMemberInputUpdateProjectTeamMemberInputUpdateTeamRegistryRoleUpdateUserRegistryRole)user_idruser_project_role)team_idrteam_project_rolergrhzFailed to update member z role to z in registry )rjrrrrrrrfrom_objkindrUSERr encoder9ENTITYrrmr"rnror|rrrr&)r.rrrrrrrrid_rxry result_clsrzr{r|r0r0r1 update_memberOs. $        zRegistry.update_memberr?) r"rr#r$r%r$r&r$r'r()r3rr4r5)r4r$)r>r$)r4rB)r>r$r4r5)r4rG)r>rGr4r5)r4r)r4rM)r4rO)r>rO)NrQ)rRrSrTrr4r)rRrSrTrr4r)NN)r"rr#r$r&r$rPrOrDrBrJr[r4r)r4r5)r4r)r4r)r4r)rrr4r)rrrrr4r)#__name__ __module__ __qualname____doc____annotations__r2r-propertyr9r<r&setterr%r#rDrIrJrKrLrNrPr rXrZ classmethodrrrrrrrrrrr0r0r0r1r&s                     G    R    99r)0 __future__rtypingrrrpydanticrtyping_extensionsrr wandb_gqlr rwandb._analyticsr wandb._strutilsr wandb.apis.public.teamsr wandb.apis.public.usersr wandb.protorrwandb.sdk.artifacts._modelsr_freezable_listr_membersrrrrrr_utilsrrrregistries_searchrrwandb.apis.public.apirrjrrr0r0r0r1s(