} SrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J r SSK J r "S S \ R5r "S S \R5rS rSrSrg)zCRM operations utilities.)absolute_import)division)unicode_literals)tags)waiter) exceptions) resourcesc\rSrSrSrg)OperationErrorN)__name__ __module__ __qualname____firstlineno____static_attributes__r =lib/googlecloudsdk/command_lib/resource_manager/operations.pyr r srr c$\rSrSrSrSrSrSrg)ReturnOperationPollerzPolls for operations that retrieve the operation rather than the resource. This is needed for Delete operations, where the response is Empty. It is also needed for services that do not have a Get* method, such as TagBindings. cXlg)zSets up poller for polling operations. Args: operation_service: apitools.base.py.base_api.BaseApiService, api service for retrieving information about ongoing operation. Noperation_service)selfrs r__init__ReturnOperationPoller.__init__&s /rcU$)a.Overrides. Response for Deletion Operation is of type google.protobuf.Empty and hence we can return the operation itself as the result. For operations without a Get[Resource] method, we have no choice but to return the operation. Args: operation: api_name_messages.Operation. Returns: operation r )r operations r GetResultReturnOperationPoller.GetResult/s  rrN)rrrr__doc__rr rr rrrrs / rrcV[[R"55n[XU5$)aWaits for the given google.longrunning.Operation to complete. Args: operation: The operation to poll. message: String to display for default progress_tracker. Raises: apitools.base.py.HttpError: if the request returns an HTTP error Returns: operation )rrOperationsService_WaitForOperation)rmessagepollers rWaitForReturnOperationr(?s$ !!7!7!9 :& 9v 66rcn[R"U[R"55n[ XU5$)axWaits for the given google.longrunning.Operation to complete. Args: operation: The operation to poll. message: String to display for default progress_tracker. service: The service to get the resource after the long running operation completes. Raises: apitools.base.py.HttpError: if the request returns an HTTP error Returns: The TagKey or TagValue resource. )rCloudOperationPollerrr$r%)rr&servicer's rWaitForOperationr,Ps,  & &w0F0F0H I& 9v 66rcURU5(aURU5$[RR UR SS9n[ R"X#U5$)Nzcloudresourcemanager.operations) collection)IsDoner r REGISTRYParsenamerWaitFor)rr&r' operation_refs rr%r%cs[ ]]9   I &&$$**nn!B+D- w 77rN)r" __future__rrr'googlecloudsdk.api_lib.resource_managerrgooglecloudsdk.api_lib.utilrgooglecloudsdk.corerr Errorr r*rr(r,r%r rrr:sS &'8.*)Z%%F77@7"7&8r