0&SrSSKJr SSKJr SSKJr SSKJ r SSKJr SSK J r SSK Jr SSKJr SS KJr SS KJr SS KJr S rS rSrSSjrSSjrS SjrS!SjrS!SjrSrS!SjrSr Sr!Sr"Sr#S"Sjr$Sr%S!Sjr&g)#z Utilities for all CRUD commands.)encoding) exceptions)util) operations)waiter) constants) pretty_print)log) resources) console_iocR[RRURSS9$)Nz+gkemulticloud.projects.locations.operations collection)r REGISTRYParseRelativeNamename)ops Flib/googlecloudsdk/command_lib/container/gkemulticloud/command_util.py_GetOperationResourcers*    - -ggG . cSnURb+[R"UR5nSU;aUSn[RR USS9$)Ntargetz1gkemulticloud.projects.locations.attachedClustersr)metadatarMessageToPyValuer rr)r op_clusterrs r_GetOperationTargetr%s[*[[((5H8H%j    - -P . rc[U5n[R"U[RS9 UR (agU(d'[ R"5nURX25 gg)N)kind) rr CreatedResourcerLRO_KINDdone op_api_utilOperationsClientWait)rasync_messageop_ref op_clients r_LogAndWaitForOperationr*0sP  $&f9#5#56WW ,,.I NN6# rNcSRUS9nU(aSRUS9U-nU(aU(aUSRX#S9- nU$)Nzcluster [{name}]r {action} action in {kind} region [{region}]rregionformat)rr/rr2msgs rClusterMessager6<sS!!t!,#   F  +c 1C f ) 0 0d 0 JJC *rcSRUS9nU(aSRUS9U-nU(aUSRUS9- nU(aU(aUSRX4S9- nU$) Nznode pool [{name}]r,r-r.z in cluster [{cluster}])clusterr0r1r3)rr/r8rr2r5s rNodePoolMessager9Eso###.#   F  +c 1C  $ + +G + <Nr&r?)UpdaterBr4r*r UpdatedResourcerCrDs rrJrJsrHrcSnU[R:Xd(U[R:XdU[R:XaUR S5nO_U[R :XdU[R :XaUR S5nO%U[R:XaUR S5n[R"[R"X!5SSS9 g)z)Generates a delete prompt for a resource.z!The following {} will be deleted.clusters node poolclientTr'throw_if_unattended cancel_on_noN) rAWS_CLUSTER_KINDAZURE_CLUSTER_KINDATTACHED_CLUSTER_KINDr4AWS_NODEPOOL_KINDAZURE_NODEPOOL_KINDAZURE_CLIENT_KINDr PromptContinuegke_util ConstructList)ritemstitles r _DeletePromptr^s -% i((( -- - 00 0 LL $E i))) .. . LL %E y*** LL "E $$U2rc[USS5nU(d [X4/5 [USS5n[USS5n[USS5nURUUUUS9n U(aSUlg[ XS U-5 [ R "XUS 9 g) avRuns a delete command for gkemulticloud. Args: resource_ref: obj, resource reference. resource_client: obj, client for the resource. args: obj, arguments parsed from the command. kind: str, the kind of resource e.g. AWS Cluster, Azure Node Pool. message: str, message to display while waiting for LRO to complete. Returns: The details of the updated resource. r=Fr& allow_missing ignore_errors)r=r`rar>Nz Deleting r?)rBr^Deleter4r*r DeletedResource) rErFrGrr'r=r&r`rars rrbrbs$7- $ " 45 )&$7-$7-!!! " DK "kG&;<l?rcSnU[R:XdU[R:XaSnUR(d [ XU5 [ UUUUUS9nU$![ Ra=nUR(d%[R"SRU55 UeSnAf[Ra=nUR(d%[R"SRU55 UeSnAff=f)aCalls the delete command and suggests using --ignore-errors on failure. Args: args: obj, arguments parsed from the command. resource_client: obj, client for the resource. resource_ref: obj, resource reference. message: str, message to display while waiting for LRO to complete. kind: str, the kind of resource e.g. AWS Cluster, Azure Node Pool. Returns: The details of the updated resource. r8rN)rErFrGr'rz9Delete {} failed. Try re-running with `--ignore-errors`. N) rrVrWra_PromptIgnoreErrorsrbrOperationErrorr Infor4apitools_exceptions HttpError)rGrFrEr'rresretes rDeleteWithIgnoreErrorsrms # i))) .. . C  |< !'    C. *!       F M M  G  & &    F M M  G s$ AC:.8B&&C:=8C55C:c URU5n[R "5nUR RRUR RRURRRURRRURRRURRRURRRURRRURRRURRR/ nURU;ag[R "SSSSS9Ulg![RanURS:XaSnAgUeSnAff=f)zNPrompt for --ignore-errors flag if the resource is in ERROR or DEGRADED state.iNzQCluster or node pool is in ERROR or DEGRADED state. Setting --ignore-errors flag.TF)r'rQrRdefault)rCrhri status_coderGetMessagesModule)GoogleCloudGkemulticloudV1AttachedClusterStateValueValuesEnumERRORDEGRADED$GoogleCloudGkemulticloudV1AwsCluster%GoogleCloudGkemulticloudV1AwsNodePool&GoogleCloudGkemulticloudV1AzureCluster'GoogleCloudGkemulticloudV1AzureNodePoolstater rYra)rGrFrEresprlmessages error_statess rreres`   | ,D  # # %(88MMSS88MMVV33HHNN33HHQQ44IIOO44IIRR55JJPP55JJSS66KKQQ66KKTT , ZZ|# !00 ,$'  & & }} G sFF>"F97F99F>c*SnURXU5$)zMessage to display after cancelling an LRO operation. Args: name: str, name of the operation. kind: str, the kind of LRO operation e.g. AWS or Azure. Returns: The operation cancellation message. zCancelation of operation {0} has been requested. Please use gcloud container {1} operations describe {2} to check if the operation has been cancelled successfully.r3)rrr5s rCancelOperationMessagers @ D %%rcRSn[R"URU5SSS9 g)zbPrompt the user before cancelling an LRO operation. Args: op_name: str, name of the operation. z$The operation {0} will be cancelled.TrPN)r rYr4)op_namer's rCancelOperationPromptr*s) 3' nnW%rcURUUUS9n[USS5nU(aSUlg[USS5n[XhU5 [ U5n [ R "XUS9 g)aRuns an import command for gkemulticloud. Args: location_ref: obj, location reference. resource_client: obj, client for the resource. fleet_membership_ref: obj, fleet membership reference. args: obj, arguments parsed from the command. kind: str, the kind of resource e.g. AWS Cluster, Azure Node Pool. message: str, message to display while waiting for LRO to complete. Returns: The details of the imported resource. ) location_reffleet_membership_refrGr=Fr>Nr&r?)ImportrBr4r*rr ImportResource) rrFrrGrr'rr=r& op_targets rrr8sq*/ " $7-DK 45 )&"g.!"%)YF;rc\Sn[R"[R"X5SSS9 g)z7Generates a rollback prompt for the node pool resource.z,The following node pool will be rolled back.TrPN)r rYrZr[)r\r]s r_RollbackPromptr\s) 8% $$U2rc[U/5 [USS5nURX5n[XeSU-5 [R "XUS9 UR U5$)axRuns a rollback command for gkemulticloud. Args: resource_ref: obj, resource reference. resource_client: obj, client for the resource. args: obj, arguments parsed from the command. kind: str, the kind of resource e.g. AWS Cluster, Azure Node Pool. message: str, message to display while waiting for LRO to complete. Returns: The details of the updated resource. r&Fz Rolling back r?)rrBRollbackr*r rKrC)rErFrGrr'r&rs rrrfs\7) 45 )& 3""o&?@l?   \ **r)NNN)NNNN)NN)NNNNN)NNNNNN)'__doc__apitools.base.pyrrrh googlecloudsdk.api_lib.containerrrZ.googlecloudsdk.api_lib.container.gkemulticloudrr#googlecloudsdk.api_lib.utilr2googlecloudsdk.command_lib.container.gkemulticloudrgooglecloudsdk.command_lib.runr googlecloudsdk.corer r googlecloudsdk.core.consoler rrr*r6r9r;rArJr^rbrmrerrrrrrrrs'&>=T?.H7#)2  $   LP+6LP+40LP@D- `D&$   !