j{#xUdZddlmZddlmZddlmZdZiZee e fe d<efdZ d d Z d ZGd d eZy)z=Wrap long-running operations returned from Google Cloud APIs.)Dict)operations_pb2) json_formatztype.googleapis.com _TYPE_URL_MAPc<|jj}|d|S)aCompute a type URL for a klass. :type klass: type :param klass: class to be used as a factory for the given type :type prefix: str :param prefix: URL prefix for the type :rtype: str :returns: the URL, prefixed as appropriate /) DESCRIPTOR full_name)klassprefixnames i/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/google/cloud/operation/__init__.py_compute_type_urlrs     % %Dd ##Nc| t|}|tvr t||urtdt||t|<y)aRegister a klass as the factory for a given type URL. :type klass: :class:`type` :param klass: class to be used as a factory for the given type :type type_url: str :param type_url: (Optional) URL naming the type. If not provided, infers the URL from the type descriptor. :raises ValueError: if a registration already exists for the URL. Nz Conflict: )rr ValueError)r type_urls r register_typer,sF$U+=  "% /}X/FHI I#M(rc^t|j}|j|jS)aConvert an ``Any`` protobuf into the actual class. Uses the type URL to do the conversion. .. note:: This assumes that the type URL is already registered. :type any_pb: :class:`google.protobuf.any_pb2.Any` :param any_pb: An any object to be converted. :rtype: object :returns: The instance (of the correct type) stored in the any instance. )rr FromStringvalue)any_pbr s r _from_anyrAs' &// *E   FLL ))rceZdZdZdZ dZ dZ dZ dZdZ e dZ e dZ e dZdZd Zd Zd Zd Zy) OperationaRepresentation of a Google API Long-Running Operation. .. _protobuf: https://github.com/googleapis/googleapis/blob/ 050400df0fdb16f63b63e9dee53819044bffc857/ google/longrunning/operations.proto#L80 .. _service: https://github.com/googleapis/googleapis/blob/ 050400df0fdb16f63b63e9dee53819044bffc857/ google/longrunning/operations.proto#L38 .. _JSON: https://cloud.google.com/speech/reference/rest/ v1beta1/operations#Operation This wraps an operation `protobuf`_ object and attempts to interact with the long-running operations `service`_ (specific to a given API). (Some services also offer a `JSON`_ API that maps the same underlying data type.) :type name: str :param name: The fully-qualified path naming the operation. :type client: :class:`~google.cloud.client.Client` :param client: The client used to poll for the status of the operation. If the operation was created via JSON/HTTP, the client must own a :class:`~google.cloud._http.Connection` to send polling requests. If created via protobuf, the client must have a gRPC stub in the ``_operations_stub`` attribute. :type caller_metadata: dict :param caller_metadata: caller-assigned metadata about the operation NTc X||_||_|j|_d|_y)NF)r clientcopycaller_metadata _complete)selfr rrs r__init__zOperation.__init__s(  .335rc ^||j|fi|}|j|d|_|S)aDFactory: construct an instance from a protobuf. :type operation_pb: :class:`~google.longrunning.operations_pb2.Operation` :param operation_pb: Protobuf to be parsed. :type client: object: must provide ``_operations_stub`` accessor. :param client: The client used to poll for the status of the operation. :type caller_metadata: dict :param caller_metadata: caller-assigned metadata about the operation :rtype: :class:`Operation` :returns: new instance, with attributes based on the protobuf. T)r _update_state _from_grpc)cls operation_pbrrresults rfrom_pbzOperation.from_pbs6"\&&B/B\*  rc tj|tj}||j|fi|}|j |d|_|S)aFactory: construct an instance from a dictionary. :type operation: dict :param operation: Operation as a JSON object. :type client: :class:`~google.cloud.client.Client` :param client: The client used to poll for the status of the operation. :type caller_metadata: dict :param caller_metadata: caller-assigned metadata about the operation :rtype: :class:`Operation` :returns: new instance, with attributes based on the protobuf. F)r ParseDictrrr r$r%)r& operationrrr'r(s r from_dictzOperation.from_dictsQ #,,Y8P8P8RS \&&B/B\*! rc|jS)z|Has the operation already completed? :rtype: bool :returns: True if already completed, else false. )r r!s rcompletezOperation.completes~~rctj|j}|jjj |S)zPolls the status of the current operation. Uses gRPC request to check. :rtype: :class:`~google.longrunning.operations_pb2.Operation` :returns: The latest status of the current operation. )r )rGetOperationRequestr r_operations_stub GetOperation)r! request_pbs r_get_operation_rpczOperation._get_operation_rpcs3$77TYYG {{++88DDrcd|j}|jjjd|}t j |t jS)zChecks the status of the current operation. Uses HTTP request to check. :rtype: :class:`~google.longrunning.operations_pb2.Operation` :returns: The latest status of the current operation. z operations/GET)methodpath)r r _connection api_requestrr+rr)r!r: api_responses r_get_operation_httpzOperation._get_operation_httpsK#'))-{{..::%d:S $$\>3K3K3MNNrcZ|jr|jS|jS)zChecks the status of the current operation. :rtype: :class:`~google.longrunning.operations_pb2.Operation` :returns: The latest status of the current operation. )r%r6r>r/s r_get_operationzOperation._get_operations) ??**, ,++- -rc|jrd|_|jdrt|j|_|j d}|dk(r|j |_y|dk(rt|j|_yy)zUpdate the state of the current object based on operation. :type operation_pb: :class:`~google.longrunning.operations_pb2.Operation` :param operation_pb: Protobuf to be parsed. Tmetadatar(errorresponseN)doner HasFieldrrB WhichOneofrCrD)r!r' result_types rr$zOperation._update_statesx   !DN   ,%l&;&;r@r$rJrrrrUs>FCH E HJ ** E O .=&rr)N)rNtypingrgoogle.longrunningrgoogle.protobufr_GOOGLE_APIS_PREFIXrstrtype__annotations__rrrobjectrrRrrr[sPD-',!# tCI#%8 $ $**(wwr