dZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd l mZdd lmZdd lmZdd lmZdd lmZdZdZGdde j2ZddZddZddZy)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'imceZdZdZfdZ ddej fdZdejde ej ddffdZ xZ S) OperationsClientz:Client for operations in Anthos GKE On-Prem API resources.c btt| di||jj|_y)N)superr__init___clientprojects_locations_operations_service)selfkwargs __class__s >DMNreturnc&|r+tjj|jd}||dznt}t j t j|j|dj|jt|S)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 rWaitzOperationsClient.Wait,s((:: ..>;m %,$7'D._K >>..t}}=077  & & ( 1 rargsc tj|j|}tj|j |dt j|dt j|ddS)zList operations.)r$ operations page_sizelimitpageSize)field batch_sizer3batch_size_attribute)messages/GkeonpremProjectsLocationsOperationsListRequest_location_namer YieldFromListrr Get)rr/list_reqs rListzOperationsClient.ListJscGG   &H  # # 99T;/iig&'  r)NNN) __name__ __module__ __qualname____doc__rr8 Operationr.r Namespacerr> __classcell__)rs@rrr%sPB? 9=<#--##T4/0rrcHtjt|dd|y)NEnrollEnrolledis_asyncr Print log_operation resource_refrJs r log_enrollrP[s))L(JJrcHtjt|dd|y)NUnenroll UnenrolledrIrKrNs r log_unenrollrTas))L*lXNrc |j}|jdd}ddddddd d d }|j|d }|j}|rd j |||Sdj |||S)a0Logs 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_tenserarb) CollectionsplitgetSelfLinkr() rOr`rcrJresource_collection resource_typeresource_type_to_namerarbs rrMrMgs%//1%++C04-;J@A ? G 6 F (++M;MN-##%) D K K# L  9 ? ?# @ rN)F)rB __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.v1rr8r*r% ClientBaserrPrTrMrrrrus[8&''=.5=#)` 3v((3l  .r