+SrSSKrSSKJr SSKJr SSKJr SSKJr SSK J r SSK J r Sr S rS rS rS rS rSSjrg)z:Utilities for the cloud deploy delivery pipeline resource.N) exceptions) client_util)delivery_pipeline)log) resourcesz#serialPipeline.stages.targetId:"{}"cH[RRUSUUUS.S9$)aCreates the delivery pipeline reference base on the parameters. Returns the shared delivery pipeline reference. Args: name: str, delivery pipeline ID project: str,project number or ID. region: str, region ID. Returns: custom target type reference. 0clouddeploy.projects.locations.deliveryPipelines) projectsId locationsIddeliveryPipelinesId) collectionparams)rREGISTRYParse)nameprojectregions ?lib/googlecloudsdk/command_lib/deploy/delivery_pipeline_util.pyDeliveryPipelineReferencer s6    ! ! C!% " c[RUR55n[R"5R UR 5USS9n[USSS9$)a3Lists the delivery pipelines associated with the specified target. The returned list is sorted by the delivery pipeline's create time. Args: target_ref: protorpc.messages.Message, target object. location_ref: protorpc.messages.Message, location object. Returns: a sorted list of delivery pipelines. r)location filter_str page_sizecUR$)N) createTime)pipelines r1ListDeliveryPipelinesWithTarget..Qs h&9&9rT)keyreverse),_PIPELINES_WITH_GIVEN_TARGET_FILTER_TEMPLATEformatNamerDeliveryPipelinesClientList RelativeNamesorted) target_ref location_refr pipeliness rListDeliveryPipelinesWithTargetr,8sg<BBoo* 779>>((*?) 94 rcV[RRURSS9nU$)Nr )r )rrParseRelativeNamer)r pipeline_refs rPipelineToPipelineRefr0Us/##55mmC6, rcF[R"5RU5nU$![Radn[ R "SRXR55 [ RRSRU55 UeSnAff=f)zGets the delivery pipeline and returns the value of its suspended field. Args: pipeline_name: str, the canonical resource name of the delivery pipeline Returns: The pipeline object Raises: apitools.base.py.HttpError zFailed to get pipeline {}: {}z"Unable to get delivery pipeline {}N) rr%Getapitools_exceptions HttpErrorrdebugr#contentstatusPrint) pipeline_name pipeline_objerrors r GetPipeliner<]s $<<>BBL   & &II'..}mmLJJ9@@OP K s%(B ABB cdUR(a[R"URUS9eg)aUChecks if the delivery pipeline associated with the release is suspended. Args: pipeline_obj: protorpc.messages.Message, delivery pipeline object. suspended_pipeline_msg: str, error msg to show the user if the pipeline is suspended. Raises: googlecloudsdk.command_lib.deploy.PipelineSuspendedError if the pipeline is suspended )r9failed_activity_msgN) suspended cd_exceptionsPipelineSuspendedErrorr)r:suspended_pipeline_msgs rThrowIfPipelineSuspendedrCus1  . ."''2 rc 0U(aUO!S[R"5R-n[R"5R XgS9n [ R"5RU[R"5RUU UUUUS95$)aCreates a rollback rollout for the target based on the given inputs. Args: pipeline_rel_name: delivery_pipeline name target_id: the target to rollback validate_only: whether or not to validate only for the call release_id: the release_id to rollback to rollout_id: the rollout_id of the new rollout rollout_to_rollback: the rollout that is being rolled back by this rollout rollout_obj: the rollout resource to pass into rollbackTargetConfig starting_phase: starting_phase of the rollout Returns: RollbackTargetResponse z rollback-)rolloutstartingPhaseId) releaseIdrollbackConfig rolloutIdrolloutToRollBacktargetId validateOnly) uuiduuid4hexrGetMessagesModuleRollbackTargetConfigrr%RollbackTargetRollbackTargetRequest) pipeline_rel_name target_id validate_only release_id rollout_idrollout_to_rollback rollout_objstarting_phase rollback_idrollback_target_configs rCreateRollbackTargetr^s6) kDJJLres^A >:@I#)*- 0:0,+r