dZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm Z d Z d Z dd Z d ZdZy )z$Utilities for the promote operation.)rollout) exceptions) release_util) rollout_util) target_util)log) resourceszmRelease {} is already deployed to the last target ({}) in the promotion sequence. - Release: {} - Target: {} zstate="IN_PROGRESS"Nc |} | s t||} tj|| |||||| } tj|| } | r+| j rt jjd| S)a@Creates a rollout for the given release in the destination target. If to_target is not specified and there is a rollout in progress, the promote will fail. Otherwise this computes the destination target based on the promotion sequence. Args: release_ref: protorpc.messages.Message, release resource object. release_obj: apitools.base.protorpclite.messages.Message, release message object. to_target: str, the target to promote the release to. is_create: bool, if creates a rollout during release creation. rollout_id: str, ID to assign to the generated rollout. annotations: dict[str,str], a dict of annotation (key,value) pairs that allow clients to store small amounts of arbitrary data in cloud deploy resources. labels: dict[str,str], a dict of label (key,value) pairs that can be used to select cloud deploy resources and to find collections of cloud deploy resources that satisfy certain conditions. description: str, rollout description. starting_phase_id: str, the starting phase for the rollout. override_deploy_policies: List of Deploy Policies to override. Raises: googlecloudsdk.command_lib.deploy.exceptions.RolloutIdExhausted googlecloudsdk.command_lib.deploy.exceptions.ReleaseInactiveError Returns: The rollout resource created. z The rollout is pending approval.) GetToTargetIDr CreateRolloutrGetSnappedTargetrequireApprovalrstatusPrint) release_ref release_obj to_target is_create rollout_id annotationslabels descriptionstarting_phase_idoverride_deploy_policies dest_targetrollout_resource target_objs 5lib/googlecloudsdk/command_lib/deploy/promote_util.pyPromoter"szR+  Y7K!//  ,,[+F*J..JJ78 c N|jjjstj|j t jj|j d}|jjjdj}tt|jjj}|j}t|D]c\}}tj|j|d|d}tj |t jj#dd|d|d|dd  } | stt jj#| j d } | j%j'|j'k(s|dkDr||d z j}n}t(j*j-t.j1|j'|j'|j3|j3|j3}n||jjjdjk(r|stj4tj6|S) aGet the to_target parameter for promote API. This checks the promotion sequence to get the next stage to promote the release to. Args: release_obj: apitools.base.protorpclite.messages.Message, release message. is_create: bool, if getting the target for release creation. Returns: the target ID. Raises: NoStagesError: if no pipeline stages exist in the release. ReleaseInactiveError: if this is not called during release creation and the specified release has no rollouts. z9clouddeploy.projects.locations.deliveryPipelines.releases) collectionr projectsId locationsIdNz0clouddeploy.projects.locations.deliveryPipelinesdeliveryPipelinesId)r#r$r%)r"paramszBclouddeploy.projects.locations.deliveryPipelines.releases.rollouts)deliveryPipelineSnapshotserialPipelinestagesr NoStagesErrornamer REGISTRYParseRelativeNametargetIdlistreversedAsDict enumeraterTargetReferenceGetCurrentRolloutParseParentNamerrr_LAST_TARGET_IN_SEQUENCEformat RelativeNameReleaseInactiveErrorTargetId) rrrrreversed_stages release_dictistage target_refcurrent_rolloutcurrent_rollout_refs rr r bs`&  - - < < C C  " ";#3#3 44""44L5+22AAHH H {33BBIIJ/##%,O,ha,,  \2L4OJ "33  I*<8+M:'34I'J !  O%..44   Y5  # # % * * , 0@0@0B B q5%a!e,55) **  &--""$//#**,))+  !--/) Q-Z  - - < < C CA F O OP  ) ) ++   i ((r cttjj|j t d}|r t j|j|y)auChecks if there are any rollouts in progress for the given release. Args: release_ref: protorpc.messages.Message, release resource object. release_obj: apitools.base.protorpclite.messages.Message, release message object. to_target_id: string, target id (e.g. 'prod') Raises: googlecloudsdk.command_lib.deploy.exceptions.RolloutInProgressError r')limitN) r0r RolloutClientListr;IN_PROGRESS_FILTER_TEMPLATErRolloutInProgressErrorr,)rr to_target_idrolloutss rCheckIfInProgressRolloutrMs^ ""  " " $&A#(   + +K,<,rSs[+78::9#)E 4 !=@W)tLr