+dZddlZddlmZddlmZddlmZddlmZ ddl m Z ddl m Z dZ d Zd Zd Zd Zd Z ddZy)z:Utilities for the cloud deploy delivery pipeline resource.N) exceptions) client_util)delivery_pipeline)log) resourcesz#serialPipeline.stages.targetId:"{}"cNtjj|d|||dS)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!% " ctj|j}tjj |j |d}t|ddS)aALists 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_sizec|jS)N) createTime)pipelines rz1ListDeliveryPipelinesWithTarget..Qs h&9&9rT)keyreverse),_PIPELINES_WITH_GIVEN_TARGET_FILTER_TEMPLATEformatNamerDeliveryPipelinesClientList RelativeNamesorted) target_ref location_refr pipeliness rListDeliveryPipelinesWithTargetr+8sg<BBoo* 779>>((*?) 94 rc\tjj|jd}|S)Nr )r )rrParseRelativeNamer)r pipeline_refs rPipelineToPipelineRefr/Us/##55mmC6, rcB tjj|}|S#tj$rd}t j dj||jt jjdj||d}~wwxYw)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'..}emmLJJ9@@OP K s$'BABBc^|jr!tj|j|y)aeChecks 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 )r8failed_activity_msgN) suspended cd_exceptionsPipelineSuspendedErrorr)r9suspended_pipeline_msgs rThrowIfPipelineSuspendedrBus1  . ."''2 rc ,|r|n dtjjz}tjj ||} t jj|tjj|| ||||S)a4Creates 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) kDJJLP  2 2 4 C C##%;;//$ <  r)FNNNNN)__doc__rLapitools.base.pyrr2"googlecloudsdk.api_lib.clouddeployrr!googlecloudsdk.command_lib.deployr?googlecloudsdk.corerrr!rr+r/r;rBr]rrrds^A >:@I#)*- 0:0,+r