,SrSSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SSK Jr SS K Jr SS KJr S rS r"S S\R*5rSSjrSSjrSSjrg)z1Utilities Anthos GKE On-Prem resource operations.) Generator) list_pager)client)waiter)parser_extensions)flags)log) resources)gkeonprem_v1_messagesi'imc^\rSrSrSrU4SjrS S\R4SjjrS\ RS\ \RSS44Sjr S r U=r$) OperationsClient"z:Client for operations in Anthos GKE On-Prem API resources.c d>[[U] "S0UD6 URRUlg)N)superr __init___clientprojects_locations_operations_service)selfkwargs __class__s >DMNreturnc*U(a([RRURSS9nUbUS-O[n[ R "[ R"UR5USRUR55[US9$)aWaits for an LRO to complete. Args: operation: object, operation to wait for. operation_ref: operation resource argument reference. timeout: int, time in seconds to wait for the operation to complete. Returns: A completed long-running operation. z'gkeonprem.projects.locations.operations) collectioniz&Waiting for operation [{}] to complete)wait_ceiling_ms max_wait_ms) r REGISTRYParseRelativeNamenameMAX_LRO_WAIT_MSrWaitForCloudOperationPollerNoResourcesrformat RelativeNameMAX_LRO_POLL_INTERVAL_MS)r operation operation_reftimeoutr s rWaitOperationsClient.Wait)s((:: ..>;m %,$7'D._K >>..t}}=077  & & ( 1 rargsc [R"URU5S9n[R"UR US[ R"US5[ R"US5SS9$)zList operations.)r# operations page_sizelimitpageSize)field batch_sizer3batch_size_attribute)messages/GkeonpremProjectsLocationsOperationsListRequest_location_namer YieldFromListrrGet)rr/list_reqs rListOperationsClient.ListGscGG   &H  # # 99T;/iig&'  r)r)NNN)__name__ __module__ __qualname____firstlineno____doc__rr8 Operationr-r Namespacerr>__static_attributes__ __classcell__)rs@rr r "sUB? 9=<#--##T4/0rr c D[R"[USSUS95 g)NEnrollEnrolledis_asyncr Print log_operation resource_refrMs r log_enrollrSXs))L(JJrc D[R"[USSUS95 g)NUnenroll UnenrolledrLrNrQs r log_unenrollrW^s))L*lXNrc UR5nURS5SnSSSSSSS S S .nURUS 5nUR5nU(aS R UUUS9$SR UUUS9$)a Logs the long running operation of a resource. Args: resource_ref: A resource argument. action: str, present tense of the operation. past_tense: str, past tense of the operation. is_async: bool, if async operation is enabled. Returns: A string that logs the operation status. .z user cluster in Anthos on VMwarez/node pool of a user cluster in Anthos on VMwarez!admin cluster in Anthos on VMwarez$user cluster in Anthos on bare metalz3node pool of a user cluster in Anthos on bare metalz%admin cluster in Anthos on bare metalz*standalone cluster in Anthos on bare metalz9node pool of a standalone cluster in Anthos on bare metal)vmwareClustersvmwareNodePoolsvmwareAdminClustersbareMetalClustersbareMetalNodePoolsbareMetalAdminClustersbareMetalStandaloneClustersbareMetalStandaloneNodePoolszunknown resourcez7{action} in progress for {resource_name} [{self_link}].)action resource_name self_linkz+{past_tense} {resource_name} [{self_link}].) past_tenserdre) CollectionsplitgetSelfLinkr') rRrcrfrMresource_collection resource_typeresource_type_to_namerdres rrPrPds%//1%++C04-;J@A ? G 6 F (++M;MN-##%) D K K# L  9 ? ?# @ rN)F)rDtypingrapitools.base.pyr*googlecloudsdk.api_lib.container.gkeonpremrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioper+googlecloudsdk.command_lib.container.vmwarergooglecloudsdk.corer r 2googlecloudsdk.generated_clients.apis.gkeonprem.v1r r8r)r$ ClientBaser rSrWrPrrrrwsT8'=.5=#)` 3v((3l  .r