SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SS K Jr SS KJr SS KJr SS KJr SS KJr SrSr"SS\ R25rSSjrSSjrSSjrg)z1Utilities Anthos GKE On-Prem resource operations.)absolute_import)division)unicode_literals) 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_MSr WaitForCloudOperationPollerNoResourcesrformat 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_sizer6batch_size_attribute)messages/GkeonpremProjectsLocationsOperationsListRequest_location_namer YieldFromListrr Get)rr2list_reqs rListOperationsClient.ListJscGG   &H  # # 99T;/iig&'  r)r)NNN)__name__ __module__ __qualname____firstlineno____doc__rr; Operationr0r NamespacerrA__static_attributes__ __classcell__)rs@rrr%sUB? 9=<#--##T4/0rrc D[R"[USSUS95 g)NEnrollEnrolledis_asyncr Print log_operation resource_refrPs r log_enrollrV[s))L(JJrc D[R"[USSUS95 g)NUnenroll UnenrolledrOrQrTs r log_unenrollrZas))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_tensergrh) CollectionsplitgetSelfLinkr*) rUrfrirPresource_collection resource_typeresource_type_to_namergrhs rrSrSgs%//1%++C04-;J@A ? G 6 F (++M;MN-##%) D K K# L  9 ? ?# @ rN)F)rG __future__rrrtypingrapitools.base.pyr*googlecloudsdk.api_lib.container.gkeonpremrgooglecloudsdk.api_lib.utilr googlecloudsdk.callioper +googlecloudsdk.command_lib.container.vmwarer googlecloudsdk.corer r 2googlecloudsdk.generated_clients.apis.gkeonprem.v1rr;r,r' ClientBaserrVrZrSrrrr{s[8&''=.5=#)` 3v((3l  .r