0dZddlmZddlmZddlmZddlmZddlm Z ddlm Z ddl m Z d Z d Zd Zd Zd ZdZdZdZdZdZdZdZy)z1Utilities for the cloud deploy describe commands.) exceptions)delivery_pipeline_util) rollout_util) target_util)log) resources)timescxtj|}d|i}|r|S|rt||||St||||S)aDescribes details specific to the individual target, delivery pipeline qualified. Args: target_ref: protorpc.messages.Message, target reference. pipeline_id: str, delivery pipeline ID. skip_pipeline_lookup: Boolean, flag indicating whether to fetch information from the pipeline(s) containing target. If set, pipeline information will not be fetched. list_all_pipelines: Boolean, flag indicating whether to fetch information from all pipelines associated with target, if set to false, it will fetch information from the most recently updated one. Returns: A dictionary of
. Target)r GetTargetDescribeTargetWithPipelineDescribeTargetWithNoPipeline) target_ref pipeline_idskip_pipeline_lookuplist_all_pipelines target_objoutputs 1lib/googlecloudsdk/command_lib/deploy/describe.pyDescribeTargetrsY$$$Z0* j !& M %j*k&, .. ( J(:F DDc|j}tjjdd|d|d|d}t j ||}t ||}|jr t|||}|S)aDescribes details specific to the individual target, delivery pipeline qualified. The output contains four sections: target - detail of the target to be described. latest release - the detail of the active release in the target. latest rollout - the detail of the active rollout in the target. deployed - timestamp of the last successful deployment. pending approvals - list rollouts that require approval. Args: target_obj: protorpc.messages.Message, target object. target_ref: protorpc.messages.Message, target reference. pipeline_id: str, delivery pipeline ID. output: A dictionary of
. Returns: A dictionary of
. Nz0clouddeploy.projects.locations.deliveryPipelines projectsId locationsId)rrdeliveryPipelinesId collectionparams) AsDictrREGISTRYParserGetCurrentRolloutSetCurrentReleaseAndRolloutrequireApprovalListPendingApprovals)rrrr target_dict pipeline_refcurrent_rollouts rr r 9s:!!#+##)) C#L1$]3!,* , 11*lK/ & ?& !*lF CF -rcTt|}|s|St||d<tttj |}|r*t |||d<|jr t||||St||\}}|r|rt|||d<|jr t||||S)aJDescribes details specific to the individual target. In addition, it will also display details about pipelines associated with the given target. The output contains the following sections: target - details of the target to be described. associated pipelines - details of the pipelines that use the target. For each associated pipeline, the following will be displayed: latest release - details of the active release in the target. latest rollout - details of the active rollout in the target. deployed - timestamp of the last successful deployment. pending approvals - list the rollouts that require approval. Args: target_obj: protorpc.messages.Message, target object. target_ref: protorpc.messages.Message, target reference. list_all_pipelines: Boolean, if true, will return information about all pipelines associated with target, otherwise, the most recently active pipeline information will be displayed. output: A dictionary of
. Returns: A dictionary of
. z'Number of associated delivery pipelineszAssociated delivery pipelineszActive Pipeline) GetTargetDeliveryPipelineslenlistmaprPipelineToPipelineRefListAllPipelineReleaseRolloutr$%ListPendingApprovalsMultiplePipelinesGetMostRecentlyActivePipelineSetMostRecentlyActivePipeliner%)rrrrsorted_pipelines pipeline_refsactive_pipeline_reflatest_rollouts rrrgsR0 ;  M69:J6K& 23 6 68HIK-.KM/#F *+!!+J vN -+HM+#'~"? ~#/f !!:':FC -rcg}|D]2}t||i}|jdg}|j|4||d<|S)aXFetches a list of pending rollouts for each pipeline and appends the result to a single list. Args: target_ref: protorpc.messages.Message, target object. pipeline_refs: protorpc.messages.Message, list of pipeline objects. output: dictionary object Returns: The modified output object with the list of pending rollouts. Pending Approvals)r%getextend)rr4rall_pending_approvalsr' result_dictapprovals_one_pipelines rr0r0sU#l&z<DK(__-@"E  !78$!6&  -rc|rntjj|jd}|j j |d<|j |d<|j |d<|S)a6Set current release and the last deployment section in the output. Args: current_rollout: protorpc.messages.Message, rollout object. output: dictionary object Returns: The modified output object with the rollout's parent release, the name of the rollout, and the time it was deployed. zBclouddeploy.projects.locations.deliveryPipelines.releases.rollouts)rzLatest releasezLatest rolloutDeployed)rr r!nameParent RelativeName deployEndTime)r(rcurrent_rollout_refs rr#r#sw#,,22W3 399;HHJF 2??AF (66F: -rc tj||}g}|D]}|j|j|r||d<|S#tj $r-}t jd|jzYd}~|Sd}~wwxYw)ahLists the rollouts in pending approval state for the specified target. Args: target_ref: protorpc.messages.Message, target object. pipeline_ref: protorpc.messages.Message, pipeline object. output: dictionary object Returns: The modified output object with the rollouts from the given pipeline pending approval on the given target. r8z"Failed to list pending approvals: N) rListPendingRolloutsappendr@apitools_exceptions HttpErrorrdebugcontent)rr'rpending_approvalspending_approvals_namesroerrors rr%r%s D$88L" $$RWW- $;f ! -  & &DII2U]]BCC -DsAAB"BBc*|j}tjjdd|d|dd} t j ||S#t j$r,}tjd|jzYd}~yd}~wwxYw)zGet all pipelines associated with a target. Args: target_ref: protorpc.messages.Message, target object. Returns: A list of delivery pipelines sorted by creation date, or an null list if there is an error fetching the pipelines. Nzclouddeploy.projects.locationsrr)rrrz&Failed to fetch pipelines for target: ) rrr r!rListDeliveryPipelinesWithTargetrHrIrwarningrK)rr& location_refrOs rr*r*s!!#+##)) 1#L1$]3* , ! A AL ""  & &KK85==HI sAB&"B  Bcpg}|D].}tj||}||j||g0|S)aKRetrieves the latest rollout for each delivery pipeline. Args: target_ref: protorpc.messages.Message, target object. pipeline_refs: protorpc.messages.Message, pipeline object. Returns: A list with element [pipeline_ref, rollout] where the rollout is the latest successful rollout of the pipeline resource. )rr"rG)rr4resultr'rollouts rGetPipelinesAndRolloutsrW sC &#l++J EG mm\7+,$ -rcZt||}|s9tjdj|j |ddfS|d\}}t j |j}|ddD]2}|\}}t j |j} | |kDs-|}|}| }4||fS)a~Retrieves latest rollout and release information for a list of delivery pipelines. Args: target_ref: protorpc.messages.Message, target object. sorted_pipeline_refs: protorpc.messages.Message, a list of pipeline objects, sorted in descending order by create time. Returns: A tuple of the pipeline with the most recent deploy time with latest rollout. z,Target: {} has no recently active pipelines.rN)rWrrJformatrBr ParseDateTimerC) rsorted_pipeline_refspipeline_rolloutsmost_recent_pipeline_refmost_recent_rolloutmost_recent_rollout_deploy_timepipeline_rollout_tupler'rVrollout_deploy_times rr1r1 s.j:NO II<CC!#$  "D ((2CA2F//$)$7$7''%)!!2!" 52L'--g.C.CD<w#K  & -rcNtj||}i}t||}|S)aRetrieves latest rollout and release information for a single delivery pipeline. Args: target_ref: protorpc.messages.Message, target object. pipeline_ref: protorpc.messages.Message, DeliveryPipeline object Returns: A content directory. )rr"r#)rr'r(rs rSetPipelineReleaseRolloutreQs, 11*lK/ & & ?& -rcrg}|D]/}t||}|j|j|i1|S)aRetrieves latest rollout and release information for each delivery pipeline. Args: target_ref: protorpc.messages.Message, target object. pipeline_refs: protorpc.messages.Message a list of DeliveryPipeline objects Returns: A content directory. )rerGrB)rr4rr'pipeline_entrys rr/r/cs@ &#l.z<HN MM<,,.?@$ -rN)__doc__apitools.base.pyrrH!googlecloudsdk.command_lib.deployrrrgooglecloudsdk.corerrgooglecloudsdk.core.utilr rr rr0r#r%r*rWr1r2rer/rrrnsa8?D:9#)*D<+\=@*268(7@"$r