rh3dZddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z Gd d ejZdd Zd Zd ZddZdZddZddZy)a6Futures for long-running operations returned from Google Cloud APIs. These futures can be used to synchronously wait for the result of a long-running operation using :meth:`Operation.result`: .. code-block:: python operation = my_api_client.long_running_method() result = operation.result() Or asynchronously using callbacks and :meth:`Operation.add_done_callback`: .. code-block:: python operation = my_api_client.long_running_method() def my_callback(future): result = future.result() operation.add_done_callback(my_callback) N) exceptions)protobuf_helpers)polling)operations_pb2) json_format)code_pb2ceZdZdZdej ffd ZedZedZ e dZ dZ d dZ d d Zd Zd ZxZS) OperationaHA Future for interacting with a Google API Long-Running Operation. Args: operation (google.longrunning.operations_pb2.Operation): The initial operation. refresh (Callable[[], ~.api_core.operation.Operation]): A callable that returns the latest state of the operation. cancel (Callable[[], None]): A callable that tries to cancel the operation. result_type (func:`type`): The protobuf type for the operation's result. metadata_type (func:`type`): The protobuf type for the operation's metadata. polling (google.api_core.retry.Retry): The configuration used for polling. This parameter controls how often :meth:`done` is polled. If the ``timeout`` argument is specified in the :meth:`result` method, it will override the ``polling.timeout`` property. retry (google.api_core.retry.Retry): DEPRECATED: use ``polling`` instead. If specified it will override ``polling`` parameter to maintain backward compatibility. Nc tt| dd|i|||_||_||_||_||_tj|_ |jy)Nr) superr __init__ _operation_refresh_cancel _result_type_metadata_type threadingLock_completion_lock_set_result_from_operation) self operationrefreshcancel result_type metadata_typerkwargs __class__s l/var/www/html/ai-insurance-compliance-backend/venv/lib/python3.12/site-packages/google/api_core/operation.pyrzOperation.__init__Is\ i'BB6B#  '+ ) 0 '')c|jS)zAgoogle.longrunning.Operation: The current long-running operation.)rrs r rzOperation.operation]sr!c|jjdsytj|j|jj S)z8google.protobuf.Message: the current operation metadata.metadataN)rHasFieldr from_any_pbrr%r#s r r%zOperation.metadatabsA'' 3++   !9!9  r!c@tjj|S)zDeserialize a ``google.longrunning.Operation`` protocol buffer. Args: payload (bytes): A serialized operation protocol buffer. Returns: ~.operations_pb2.Operation: An Operation protobuf object. )rr FromString)rpayloads r deserializezOperation.deserializels''227;;r!c|j5|jjr |jr dddy|jj drFt j |j|jj}|j|n|jj drtj|jjj|jjj|jjf|j}|j|n&tj d}|j|dddy#1swYyxYw)zASet the result or exception from the operation if it is complete.Nresponseerror) status_codemessageerrorsr-zLUnexpected state: Long-running operation had neither response nor error set.)rrdone _result_setr&rr'rr- set_resultrfrom_grpc_statusr.coder0 set_exceptionGoogleAPICallError)rr- exceptions r rz$Operation._set_result_from_operationxs!  " " . ??''4+;+;  . .'' 3+77%%t'?'?)))'2&77 $ 5 5 : : OO1199 OO113!__  ""9-&99. ""9-5 . . .s$E+D(E++E4c|jjs:|r|j|n|j|_|jyy)zRefresh the operation and update the result if needed. Args: retry (google.api_core.retry.Retry): (Optional) How to retry the RPC. )retryN)rr2rrrr;s r _refresh_and_updatezOperation._refresh_and_updates>##r{sa0&,*-'R %%R jK, *N6* 0#HL!Hr!