1JSrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r SSK J r SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SrSrSrS!SjrS"SjrS#SjrS$Sjr S$Sjr!Sr"S$Sjr#Sr$Sr%Sr&Sr'S%Sjr(Sr)S$S jr*g)&z Utilities for all CRUD commands.)absolute_import)division)unicode_literals)encoding) exceptions)util) operations)waiter) constants) pretty_print)log) resources) console_iocR[RRURSS9$)Nz+gkemulticloud.projects.locations.operations collection)rREGISTRYParseRelativeNamename)ops Flib/googlecloudsdk/command_lib/container/gkemulticloud/command_util.py_GetOperationResourcer"s*    - -ggG . cSnURb+[R"UR5nSU;aUSn[RR USS9$)Ntargetz1gkemulticloud.projects.locations.attachedClustersr)metadatarMessageToPyValuerrr)r op_clusterrs r_GetOperationTargetr (s[*[[((5H8H%j    - -P . rc[U5n[R"U[RS9 UR (agU(d'[ R"5nURX25 gg)N)kind) rr CreatedResourcer LRO_KINDdone op_api_utilOperationsClientWait)rasync_messageop_ref op_clients r_LogAndWaitForOperationr-3sP  $&f9#5#56WW ,,.I NN6# rNcSRUS9nU(aSRUS9U-nU(aU(aUSRX#S9- nU$)Nzcluster [{name}]r {action} action in {kind} region [{region}]r"regionformat)rr2r"r5msgs rClusterMessager9?sS!!t!,#   F  +c 1C f ) 0 0d 0 JJC *rcSRUS9nU(aSRUS9U-nU(aUSRUS9- nU(aU(aUSRX4S9- nU$) Nznode pool [{name}]r/r0r1z in cluster [{cluster}])clusterr3r4r6)rr2r;r"r5r8s rNodePoolMessager<Hso###.#   F  +c 1C  $ + +G + <SsQ  d +#   F  +c 1C   " "& " 11C *rcURX5n[USS5nU(aSUlg[USS5n[XWU5 [R "XUS9 UR U5$)avRuns a create 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 created resource. validate_onlyFdisableNr)r"is_async)Creategetattrr7r-r r#Get resource_refresource_clientargsr"r*rr@r)s rrDrD\hl1"$7-DK 45 )&"g.l?   \ **rcURX5n[USS5nU(aSUlg[USS5n[XWU5 [R "XUS9 UR U5$)awRuns an update 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@FrANr)rB)UpdaterEr7r-r UpdatedResourcerFrGs rrMrMvrKrcSnU[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) r AWS_CLUSTER_KINDAZURE_CLUSTER_KINDATTACHED_CLUSTER_KINDr7AWS_NODEPOOL_KINDAZURE_NODEPOOL_KINDAZURE_CLIENT_KINDrPromptContinuegke_util ConstructList)r"itemstitles r _DeletePromptras -% 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@rcrdrANz Deleting rB)rEraDeleter7r-r DeletedResource) rHrIrJr"r*r@r)rcrdrs rreres$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. r;rQ)rHrIrJr*r"z9Delete {} failed. Try re-running with `--ignore-errors`. N) r rYrZrd_PromptIgnoreErrorsrer OperationErrorr Infor7apitools_exceptions HttpError)rJrIrHr*r"resretes rDeleteWithIgnoreErrorsrps # 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*rTrUdefault)rFrkrl status_coderGetMessagesModule)GoogleCloudGkemulticloudV1AttachedClusterStateValueValuesEnumERRORDEGRADED$GoogleCloudGkemulticloudV1AwsCluster%GoogleCloudGkemulticloudV1AwsNodePool&GoogleCloudGkemulticloudV1AzureCluster'GoogleCloudGkemulticloudV1AzureNodePoolstaterr\rd)rJrIrHrespromessages error_statess rrhrhs`   | ,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.r6)rr"r8s 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.TrSN)rr\r7)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_refrJr@FrANr)rB)ImportrEr7r-r r ImportResource) rrIrrJr"r*rr@r) op_targets rrr;sq*/ " $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.TrSN)rr\r]r^)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 rB)rrERollbackr-r rNrF)rHrIrJr"r*r)rs rrris\7) 45 )& 3""o&?@l?   \ **r)NNN)NNNN)NN)NNNNN)NNNNNN)+__doc__ __future__rrrapitools.base.pyrrrk googlecloudsdk.api_lib.containerrr].googlecloudsdk.api_lib.container.gkemulticloudr r&googlecloudsdk.api_lib.utilr 2googlecloudsdk.command_lib.container.gkemulticloudr googlecloudsdk.command_lib.runr googlecloudsdk.corer rgooglecloudsdk.core.consolerrr r-r9r<r>rDrMrarerprhrrrrrrrrs'&'%>=T?.H7#)2  $   LP+6LP+40LP@D- `D&$   !