%SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK Jr SSK J r SSK J r SSKJr S rS rS rS rS rSrSrSrSrSrSrSrSSjrS\4SjrSS\R>4Sjjr Sr!Sr"S\4Sjr#g)z0Utilities for the cloud deploy rollout resource.) exceptions) client_util)release)rollout)log) resources)clouddeploy_v1_messageszBclouddeploy.projects.locations.deliveryPipelines.releases.rolloutszMapprovalState="NEEDS_APPROVAL" AND state="PENDING_APPROVAL" AND targetId="{}"zg(approvalState!="REJECTED" AND approvalState!="NEEDS_APPROVAL") AND state="SUCCEEDED" AND targetId="{}"z targetId="{}"z{}-to-{}-{:04d}z {}/releases/-zDeployEndTime desczCreateTime desczEnqueueTime desccF[RRU[S9$)zReturns a rollout reference object from a rollout message. Args: rollout_name: str, full canonical resource name of the rollout Returns: Rollout reference object  collection)rREGISTRYParseRelativeName_ROLLOUT_COLLECTION) rollout_names 5lib/googlecloudsdk/command_lib/deploy/rollout_util.pyRolloutReferenceFromNamer/s(    - -2 . cvUnSU;a0[RRU[S9R 5nU$)zgReturns rollout ID. Args: rollout_name_or_id: str, rollout full name or ID. Returns: Rollout ID. z projects/r )rr rrName)rollout_name_or_id rollout_ids r RolloutIdr=sE"*&&##55':6 df rc[RUR55n[RUR 55n[ R "5RUU[S9$)aLists the rollouts in PENDING_APPROVAL state for the releases associated with the specified target. The rollouts must be approvalState=NEEDS_APPROVAL and state=PENDING_APPROVAL. The returned list is sorted by rollout's create time. Args: target_ref: protorpc.messages.Message, target object. pipeline_ref: protorpc.messages.Message, pipeline object. Returns: a sorted list of rollouts. ) release_name filter_strorder_by) PENDING_APPROVAL_FILTER_TEMPLATEformatrWILDCARD_RELEASE_NAME_TEMPLATE RelativeNamer RolloutClientListPENDING_ROLLOUT_ORDERBY) target_ref pipeline_refrparents rListPendingRolloutsr'Os^066z7HI* ) 0 01J1J1L M&    % %& & rNc[RUR55n[R"5R UURUR 55UUUS9$)aGets successfully deployed rollouts for the releases associated with the specified target and index. Args: target_ref: protorpc.messages.Message, target object. pipeline_ref: protorpc.messages.Message, pipeline object. filter_str: Filter string to use when listing rollouts. order_by: order_by field to use when listing rollouts. page_size: int, the maximum number of objects to return per page. limit: int, the maximum number of `Rollout` objects to return. Returns: a rollout object or None if no rollouts in the target. )rrr page_sizelimit)rrr rr!r"r)r$r%rrr)r*r&s rGetFilteredRolloutsr+gs_ * 0 01J1J1L M&    % %"":??#45  & rreturnc@[RU5n[R"5R UR 5U5n[ UR5X5$![Ra% [R"UR 55ef=fN) !ROLLOUT_IN_TARGET_FILTER_TEMPLATErrr!r"r ComputeRolloutIDrapitools_exceptions HttpError cd_exceptionsListRolloutsError) to_target release_refrrolloutss rGenerateRolloutIdr8s077 B*F$$&++  "JH K,,. DD  & &F  ) )+*B*B*D EEFs A A$$9Bc @UnU(d [X5nUR5n [RR U[ U R S5U R S5U R S5UR5S.S9n [R"5RU R5UUS9n [RRSRU R5U55 [ R""5R%U U UUUU5n [RR'U R(SS 9n [R*"5R-U U S 5 [ R""5R/U R55$) aCreates a rollout by calling the rollout create API and waits for the operation to finish. Args: release_ref: protorpc.messages.Message, release resource object. to_target: str, the target to create create the rollout in. rollout_id: str, rollout ID. 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, rollout starting phase. override_deploy_policies: List of Deploy Policies to override. Raises: ListRolloutsError: an error occurred calling rollout list API. Returns: The rollout resource created. projectsId locationsIddeliveryPipelinesId)r:r;r< releasesId)r params)nametargetId descriptionz Creating rollout {} in target {}z)clouddeploy.projects.locations.operationsr z2Waiting for rollout creation operation to complete)r8AsDictrr ParsergetrrGetMessagesModuleRolloutr rstatusPrintrrr!Createrr?OperationsClientWaitForOperationGet)r6r5r annotationslabelsrAstarting_phase_idoverride_deploy_policiesfinal_rollout_id resource_dict rollout_ref rollout_obj operation operation_refs r CreateRolloutrWs@  (@$$&-""(($%)),7&**=9!.!2!23H!I#((* ) +--/77  # # %8+ **(//  " " $i ##%,,  )$$66nn!L7- 11:    $ $[%=%=%? @@rc [UU[[SSS9n/nUHOnU(dURU5 O![ U5(dURU5 [ U5S:dMN U$ U$)aGets the currently deployed release and the next valid release that can be rolled back to. Args: target_ref: protorpc.messages.Message, target resource object. pipeline_ref: protorpc.messages.Message, pipeline resource object. Raises: HttpException: an error occurred fetching a resource. Returns: An list containg the currently deployed release and the next valid deployable release. N )r$r%rrr*r))r+ DEPLOYED_ROLLOUT_FILTER_TEMPLATESUCCEED_ROLLOUT_ORDERBYappend_RolloutIsFromAbandonedReleaselen)r$r%iterabler7rTs rGetValidRollBackCandidaterasr!1&  ((k ook" +K 8 8ook" 8} / /rc.[UR5nUR5n[R"5R UR 55nUR$![Ran[R"U5eSnAff=fr.) rr?Parentr ReleaseClientrLr r1r2r HttpException abandoned)rTrSr6 release_objerrors rr^r^s~()9)9:+""$+*'')--k.F.F.HIK     & &*  " "5 ))*s2A%%B9BBcUVs1sHn[UR5iM nn[SS5H"n[R XU5nXd;dM Us $ [ R "U5es snf)a\Generates a rollout ID. Args: release_id: str, release ID. target_id: str, target ID. rollouts: [apitools.base.protorpclite.messages.Message], list of rollout messages. Returns: rollout ID. Raises: googlecloudsdk.command_lib.deploy.exceptions.RolloutIdExhaustedError: if there are more than 1000 rollouts with auto-generated ID. i)rr?rangeROLLOUT_ID_TEMPLATErr3RolloutIDExhaustedError) release_id target_idr7r rollout_idsirs rr0r0si -55Hq166"H+5 D>a%++J1EJ$   --j996sA.)NN)NNNNNN)$__doc__apitools.base.pyrr1"googlecloudsdk.api_lib.clouddeployrrrgooglecloudsdk.calliope!googlecloudsdk.command_lib.deployr3googlecloudsdk.corerr4googlecloudsdk.generated_clients.apis.clouddeploy.v1r rrr[r/rlrr\r#ENQUEUETIME_ROLLOUT_ORDERBYrrr'r+strr8rFrWrar^r0rrr}s7>:66.I#)XI1! O!%4!'!0.+0 $2KO6FF !KA$$KA\B::r