SrSSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ r SS KJ r S r S rSS jrSSjr"SS\R"5r"SS\5rg )z"Utilities for the clouddeploy API.)absolute_import)division)unicode_literals)apis)waiter) exceptions)log) resources clouddeployv1Nc@U=(d [5nUR$)zReturns the messages module for Cloud Deploy. Args: client: base_api.BaseApiClient, the client class for Cloud Deploy. Returns: Module containing the definitions of messages for Cloud Deploy. )GetClientInstanceMESSAGES_MODULEclients 5lib/googlecloudsdk/api_lib/clouddeploy/client_util.pyGetMessagesModulers  (&(&   cH[R"[[U(+S9$)zReturns an instance of the Cloud Deploy client. Args: use_http: bool, True to create an http object for this client. Returns: base_api.BaseApiClient, An instance of the Cloud Deploy client. )no_http)rr _API_NAME _API_VERSION)use_https rrr,s    Xl[[U]URRRURRR5 g)ztInitiates a DeployOperationPoller. Args: client: base_api.BaseApiClient, An instance of the Cloud Deploy client. N)rsuperr__init__projects_locations_operations)selfr __class__s rrDeployOperationPoller.__init__?sD K  ++II++IIKrc8URRU5$N)rGetr! operation_refs rPollDeployOperationPoller.PollJs ;;??= ))rcU$r%)r! operations r GetResultDeployOperationPoller.GetResultMs rr) __name__ __module__ __qualname____firstlineno____doc__rr)r.__static_attributes__ __classcell__)r"s@rrr8s K*rrc8\rSrSrSrS SjrSrS SjrSrSr g) OperationsClientQz:High-level client for the cloud deploy operations surface.Nc|U=(d [5UlU=(d URRUlg)zInitiates an OperationsClient. Args: client: base_api.BaseApiClient, An instance of the Cloud Deploy client. messages: messages module for Cloud Deploy. N)rrrmessages)r!rr;s rrOperationsClient.__init__Ts*/-/DK; ; ;DMrcURRRURR UR 5S95$)N)name)rr r&r;0ClouddeployProjectsLocationsOperationsGetRequest RelativeNamer's rr&OperationsClient.Get^sC ;; 4 4 8 8 FF++- G / 00rc[U5nURU5(aU$UcSRUR55n[R "XBU5$)aWait until the operation is complete or times out. Args: operation: The operation resource to wait on operation_ref: The operation reference to the operation resource. It's the result by calling resources.REGISTRY.Parse message: str, the message to print while waiting. Returns: The operation resource when it has completed Raises: OperationTimeoutError: when the operation polling times out OperationError: when the operation completed with an error zWaiting for operation [{}])rIsDoneformatNamerWaitFor)r!r-r(messagepollers rWaitForOperation!OperationsClient.WaitForOperationcsR #4 (F }}Y ,33M4F4F4HIg >>& 99rcUR5Hup4U(aUR(dM[RR URSS9nUR XESR U55Rn[RRUR U55 M g![Ra9n[RRSR U55 SnAMSnAff=f)aBChecks operations status. Only logs the errors instead of re-throwing them. Args: operation_dict: dict[str, oOptional[clouddeploy_messages.Operation], dictionary of resource name and clouddeploy_messages.Operation. The operation can be None if the operation isn't executed. msg_template: output string template. z)clouddeploy.projects.locations.operations) collectionz(Waiting for the operation on resource {}zOperation failed: {}N) itemsr>r REGISTRYParseRelativeNamerIrDresponser statusPrintcore_exceptionsError)r!operation_dict msg_template resource_namer-r(_es rCheckOperationStatus%OperationsClient.CheckOperationStatus{s%3$8$8$: inn ;!**<< NNB=D   ! !  6 = =  !) ,,];<%; " "; /66q9::;sBB77D .C??D)rr;)NNr%) r0r1r2r3r4rr&rIrZr5r,rrr8r8QsB<0 :0;rr8r%)T)r4 __future__rrrgooglecloudsdk.api_lib.utilrrgooglecloudsdk.corerrSr r rrrrCloudOperationPollerrobjectr8r,rrrasW)&',.=#)      QF772D;vD;r