#rdZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z Gd d e Zy ) z2Support library to handle the rollout subcommands.)absolute_import)division)unicode_literals) list_pager) client_util) deploy_util)logcjeZdZdZd dZd dZdZ ddZ ddZ d dZ d d Z d d Z d d Z y) RolloutClientz3Client for release service in the Cloud Deploy API.Nc|xstj|_|xstj||_|jj |_y)zInitialize a release.ReleaseClient. Args: client: base_api.BaseApiClient, the client class for Cloud Deploy. messages: module containing the definitions of messages for Cloud Deploy. N)rGetClientInstanceclientGetMessagesModulemessages6projects_locations_deliveryPipelines_releases_rollouts_service)selfrrs 1lib/googlecloudsdk/api_lib/clouddeploy/rollout.py__init__zRolloutClient.__init__sD;K99;DKE = =f EDM JJ Mc|g}|jj||jj||}|jj |S)aCalls the approve API to approve or reject a rollout.. Args: name: Name of the Rollout. Format is projects/{project}/locations/{location}/deliveryPipelines/{deliveryPipeline}/releases/{release}/rollouts/{rollout}. approved: True = approve; False = reject override_deploy_policies: List of Deploy Policies to override. Returns: ApproveRolloutResponse message. )approvedoverrideDeployPolicy)nameapproveRolloutRequest)rKClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsApproveRequestApproveRolloutRequestrApprove)rrroverride_deploy_policiesrequests rrzRolloutClient.Approve,sb '!#mmgg "mmAA!9B hG ==  ))rcp|jj|}|jj|S)zpGets a rollout resource. Args: name: rollout resource name. Returns: rollout message. )r)rGClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsGetRequestrGet)rrr s rr#zRolloutClient.GetCs8mmcc dG ==  W %%rc|jj|||}tj|j|d||dS)aLists rollout resources that belongs to a release. Args: release_name: str, name of the release. filter_str: optional[str], list filter. order_by: optional[str], field to sort by. limit: optional[int], the maximum number of `Rollout` objects to return. page_size: optional[int], the number of `Rollout` objects to return per request. Returns: Rollout list response. )parentfilterorderByrolloutspageSize)fieldlimit batch_sizebatch_size_attribute)rHClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsListRequestr YieldFromListr)r release_name filter_strorder_byr+ page_sizer s rListzRolloutClient.ListQsP*mmddJeG  # # '  rcvtjd|tj|j|tj j |||g}|jj|jj||j||}|jj|S)aCreates a rollout resource. Args: rollout_ref: protorpc.messages.Message, rollout resource object. rollout_obj: apitools.base.protorpclite.messages.Message, rollout message. 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. starting_phase_id: a str that specifies the rollout starting phase. override_deploy_policies: List of Deploy Policies to override. Returns: The operation message. zCreating rollout: %r)r%rollout rolloutIdstartingPhaseIdr) r debugr SetMetadatar ResourceTypeROLLOUTJClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsCreateRequestParent RelativeNameNamerCreate)r rollout_ref rollout_obj annotationslabelsstarting_phase_idrr s rrAzRolloutClient.Creaters4II$k2   ((  '!#mmff!!#002""$)5 gG ==   ((rc|g}|jj||jj|||}|jj |S)aCalls the retryjob API to retry a job on a rollout. Args: name: Name of the Rollout. Format is projects/{project}/locations/{location}/deliveryPipelines/{deliveryPipeline}/releases/{release}/rollouts/{rollout}. job: The job id on the rollout resource. phase: The phase id on the rollout resource. override_deploy_policies: List of Deploy Policies to override. Returns: RetryJobResponse message. jobIdphaseIdr)r6retryJobRequest)rLClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsRetryJobRequestRetryJobRequestrRetryJobrrjobphaserr s rrNzRolloutClient.RetryJobsd& '!#mmhh 55!96 iG == ! !' **rc|g}|jj||jj||}|jj |S)aCalls the AdvanceRollout API to advance a rollout to the next phase. Args: name: Name of the Rollout. Format is projects/{project}/locations/{location}/deliveryPipelines/{deliveryPipeline}/releases/{release}/rollouts/{rollout}. phase: The phase id on the rollout resource. override_deploy_policies: List of Deploy Policies to override. Returns: AdvanceRolloutResponse message. )rJr)radvanceRolloutRequest)rKClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsAdvanceRequestAdvanceRolloutRequestrAdvance)rrrQrr s rAdvanceRolloutzRolloutClient.AdvanceRolloutsb" '!#mmgg "mmAA!9B hG ==  ))rc|g}|jj||jj|}|jj |S)a_Calls the CancelRollout API to cancel a rollout. Args: name: Name of the Rollout. Format is projects/{project}/locations/{location}/deliveryPipelines/{deliveryPipeline}/releases/{release}/rollouts/{rollout}. override_deploy_policies: List of Deploy Policies to override. Returns: CancelRolloutResponse message. )r)rcancelRolloutRequest)rJClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsCancelRequestCancelRolloutRequestrCancel)rrrr s r CancelRolloutzRolloutClient.CancelRollouts_ '!#mmff !]]??!9@ gG ==   ((rc|g}|jj||jj|||}|jj |S)aCalls the IgnoreJob API to ignore a job on a rollout within a specified phase. Args: name: Name of the Rollout. Format is projects/{project}/locations/{location}/deliveryPipelines/{deliveryPipeline}/releases/{release}/rollouts/{rollout}. job: The job id on the rollout resource. phase: The phase id on the rollout resource. override_deploy_policies: List of Deploy Policies to override. Returns: IgnoreJobResponse message. rH)r6ignoreJobRequest)rMClouddeployProjectsLocationsDeliveryPipelinesReleasesRolloutsIgnoreJobRequestIgnoreJobRequestr IgnoreJobrOs rrbzRolloutClient.IgnoreJobsd '!#mmii77!98 jG == " "7 ++r)NN)N)NNNN) __name__ __module__ __qualname____doc__rrr#r4rArNrWr]rbrrr r s[; *. &"  J #,)f $ +H $ *:),,rr N)rf __future__rrrapitools.base.pyr"googlecloudsdk.api_lib.clouddeployr!googlecloudsdk.command_lib.deployrgooglecloudsdk.corer objectr rgrrrns-9&'':9#o,Fo,r