File manager - Edit - /home/newsbmcs.com/public_html/static/img/logo/future.tar
Back
_helpers.py 0000644 00000002340 15030317645 0006722 0 ustar 00 # Copyright 2017, Google LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. """Private helpers for futures.""" import logging import threading _LOGGER = logging.getLogger(__name__) def start_daemon_thread(*args, **kwargs): """Starts a thread and marks it as a daemon thread.""" thread = threading.Thread(*args, **kwargs) thread.daemon = True thread.start() return thread def safe_invoke_callback(callback, *args, **kwargs): """Invoke a callback, swallowing and logging any exceptions.""" # pylint: disable=bare-except # We intentionally want to swallow all exceptions. try: return callback(*args, **kwargs) except Exception: _LOGGER.exception("Error while executing Future callback.") base.py 0000644 00000003343 15030317645 0006037 0 ustar 00 # Copyright 2017, Google LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. """Abstract and helper bases for Future implementations.""" import abc class Future(object, metaclass=abc.ABCMeta): # pylint: disable=missing-docstring # We inherit the interfaces here from concurrent.futures. """Future interface. This interface is based on :class:`concurrent.futures.Future`. """ @abc.abstractmethod def cancel(self): raise NotImplementedError() @abc.abstractmethod def cancelled(self): raise NotImplementedError() @abc.abstractmethod def running(self): raise NotImplementedError() @abc.abstractmethod def done(self): raise NotImplementedError() @abc.abstractmethod def result(self, timeout=None): raise NotImplementedError() @abc.abstractmethod def exception(self, timeout=None): raise NotImplementedError() @abc.abstractmethod def add_done_callback(self, fn): # pylint: disable=invalid-name raise NotImplementedError() @abc.abstractmethod def set_result(self, result): raise NotImplementedError() @abc.abstractmethod def set_exception(self, exception): raise NotImplementedError() async_future.py 0000644 00000012353 15030317645 0007635 0 ustar 00 # Copyright 2020, Google LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. """AsyncIO implementation of the abstract base Future class.""" import asyncio from google.api_core import exceptions from google.api_core import retry from google.api_core import retry_async from google.api_core.future import base class _OperationNotComplete(Exception): """Private exception used for polling via retry.""" pass RETRY_PREDICATE = retry.if_exception_type( _OperationNotComplete, exceptions.TooManyRequests, exceptions.InternalServerError, exceptions.BadGateway, ) DEFAULT_RETRY = retry_async.AsyncRetry(predicate=RETRY_PREDICATE) class AsyncFuture(base.Future): """A Future that polls peer service to self-update. The :meth:`done` method should be implemented by subclasses. The polling behavior will repeatedly call ``done`` until it returns True. .. note:: Privacy here is intended to prevent the final class from overexposing, not to prevent subclasses from accessing methods. Args: retry (google.api_core.retry.Retry): The retry configuration used when polling. This can be used to control how often :meth:`done` is polled. Regardless of the retry's ``deadline``, it will be overridden by the ``timeout`` argument to :meth:`result`. """ def __init__(self, retry=DEFAULT_RETRY): super().__init__() self._retry = retry self._future = asyncio.get_event_loop().create_future() self._background_task = None async def done(self, retry=DEFAULT_RETRY): """Checks to see if the operation is complete. Args: retry (google.api_core.retry.Retry): (Optional) How to retry the RPC. Returns: bool: True if the operation is complete, False otherwise. """ # pylint: disable=redundant-returns-doc, missing-raises-doc raise NotImplementedError() async def _done_or_raise(self): """Check if the future is done and raise if it's not.""" result = await self.done() if not result: raise _OperationNotComplete() async def running(self): """True if the operation is currently running.""" result = await self.done() return not result async def _blocking_poll(self, timeout=None): """Poll and await for the Future to be resolved. Args: timeout (int): How long (in seconds) to wait for the operation to complete. If None, wait indefinitely. """ if self._future.done(): return retry_ = self._retry.with_timeout(timeout) try: await retry_(self._done_or_raise)() except exceptions.RetryError: raise asyncio.TimeoutError( "Operation did not complete within the designated " "timeout." ) async def result(self, timeout=None): """Get the result of the operation. Args: timeout (int): How long (in seconds) to wait for the operation to complete. If None, wait indefinitely. Returns: google.protobuf.Message: The Operation's result. Raises: google.api_core.GoogleAPICallError: If the operation errors or if the timeout is reached before the operation completes. """ await self._blocking_poll(timeout=timeout) return self._future.result() async def exception(self, timeout=None): """Get the exception from the operation. Args: timeout (int): How long to wait for the operation to complete. If None, wait indefinitely. Returns: Optional[google.api_core.GoogleAPICallError]: The operation's error. """ await self._blocking_poll(timeout=timeout) return self._future.exception() def add_done_callback(self, fn): """Add a callback to be executed when the operation is complete. If the operation is completed, the callback will be scheduled onto the event loop. Otherwise, the callback will be stored and invoked when the future is done. Args: fn (Callable[Future]): The callback to execute when the operation is complete. """ if self._background_task is None: self._background_task = asyncio.get_event_loop().create_task( self._blocking_poll() ) self._future.add_done_callback(fn) def set_result(self, result): """Set the Future's result.""" self._future.set_result(result) def set_exception(self, exception): """Set the Future's exception.""" self._future.set_exception(exception) __pycache__/__init__.cpython-310.pyc 0000644 00000000501 15030317645 0013214 0 ustar 00 o �h� � @ s d Z ddlmZ dgZdS )z1Futures for dealing with asynchronous operations.� )�Futurer N)�__doc__�google.api_core.future.baser �__all__� r r �R/usr/local/CyberCP/lib/python3.10/site-packages/google/api_core/future/__init__.py�<module> s __pycache__/async_future.cpython-310.pyc 0000644 00000012401 15030317645 0014166 0 ustar 00 o �h� � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddlmZ G dd� de�Z e� e ej ej ej �Zejed �ZG d d � d ej�ZdS ) z9AsyncIO implementation of the abstract base Future class.� N)� exceptions)�retry)� retry_async)�basec @ s e Zd ZdZdS )�_OperationNotCompletez-Private exception used for polling via retry.N)�__name__� __module__� __qualname__�__doc__� r r �V/usr/local/CyberCP/lib/python3.10/site-packages/google/api_core/future/async_future.pyr s r )� predicatec sv e Zd ZdZef� fdd� Zefdd�Zdd� Zdd � Zdd d �Z dd d�Z ddd�Z dd� Z dd� Z dd� Z� ZS )� AsyncFuturea� A Future that polls peer service to self-update. The :meth:`done` method should be implemented by subclasses. The polling behavior will repeatedly call ``done`` until it returns True. .. note:: Privacy here is intended to prevent the final class from overexposing, not to prevent subclasses from accessing methods. Args: retry (google.api_core.retry.Retry): The retry configuration used when polling. This can be used to control how often :meth:`done` is polled. Regardless of the retry's ``deadline``, it will be overridden by the ``timeout`` argument to :meth:`result`. c s( t � �� || _t�� �� | _d | _d S �N)�super�__init__�_retry�asyncio�get_event_loop� create_future�_future�_background_task��selfr �� __class__r r r : s zAsyncFuture.__init__c � s �t � �)z�Checks to see if the operation is complete. Args: retry (google.api_core.retry.Retry): (Optional) How to retry the RPC. Returns: bool: True if the operation is complete, False otherwise. )�NotImplementedErrorr r r r �done@ s � zAsyncFuture.donec � s �| � � I dH }|s t� �dS )z2Check if the future is done and raise if it's not.N)r r �r �resultr r r �_done_or_raiseL s ��zAsyncFuture._done_or_raisec � s �| � � I dH }| S )z+True if the operation is currently running.N)r r r r r �runningR s �zAsyncFuture.runningNc � sP �| j �� rdS | j�|�}z || j�� I dH W dS tjy' t�d��w )z�Poll and await for the Future to be resolved. Args: timeout (int): How long (in seconds) to wait for the operation to complete. If None, wait indefinitely. Nz9Operation did not complete within the designated timeout.) r r r � with_timeoutr r � RetryErrorr � TimeoutError)r �timeout�retry_r r r �_blocking_pollW s � ��zAsyncFuture._blocking_pollc � � �| j |d�I dH | j�� S )a� Get the result of the operation. Args: timeout (int): How long (in seconds) to wait for the operation to complete. If None, wait indefinitely. Returns: google.protobuf.Message: The Operation's result. Raises: google.api_core.GoogleAPICallError: If the operation errors or if the timeout is reached before the operation completes. �r% N)r' r r �r r% r r r r k s � zAsyncFuture.resultc � r( )a' Get the exception from the operation. Args: timeout (int): How long to wait for the operation to complete. If None, wait indefinitely. Returns: Optional[google.api_core.GoogleAPICallError]: The operation's error. r) N)r' r � exceptionr* r r r r+ } s � zAsyncFuture.exceptionc C s. | j du rt�� �| �� �| _ | j�|� dS )ax Add a callback to be executed when the operation is complete. If the operation is completed, the callback will be scheduled onto the event loop. Otherwise, the callback will be stored and invoked when the future is done. Args: fn (Callable[Future]): The callback to execute when the operation is complete. N)r r r � create_taskr' r �add_done_callback)r �fnr r r r- � s �z AsyncFuture.add_done_callbackc C � | j �|� dS )zSet the Future's result.N)r � set_resultr r r r r0 � � zAsyncFuture.set_resultc C r/ )zSet the Future's exception.N)r � set_exception)r r+ r r r r2 � r1 zAsyncFuture.set_exceptionr )r r r r � DEFAULT_RETRYr r r r! r' r r+ r- r0 r2 � __classcell__r r r r r ( s r )r r �google.api_corer r r �google.api_core.futurer � Exceptionr �if_exception_type�TooManyRequests�InternalServerError� BadGateway�RETRY_PREDICATE� AsyncRetryr3 �Futurer r r r r �<module> s � __pycache__/base.cpython-310.pyc 0000644 00000003301 15030317645 0012370 0 ustar 00 o �h� � @ s& d Z ddlZG dd� deejd�ZdS )z5Abstract and helper bases for Future implementations.� Nc @ s� e Zd ZdZejdd� �Zejdd� �Zejdd� �Zejdd � �Z ejdd d ��Z ejdd d��Z ejdd� �Z ejdd� �Z ejdd� �Zd S )�FuturezZFuture interface. This interface is based on :class:`concurrent.futures.Future`. c C � t � ��N��NotImplementedError��self� r �N/usr/local/CyberCP/lib/python3.10/site-packages/google/api_core/future/base.py�cancel � z Future.cancelc C r r r r r r r � cancelled! r zFuture.cancelledc C r r r r r r r �running% r zFuture.runningc C r r r r r r r �done) r z Future.doneNc C r r r �r �timeoutr r r �result- r z Future.resultc C r r r r r r r � exception1 r zFuture.exceptionc C r r r )r �fnr r r �add_done_callback5 s zFuture.add_done_callbackc C r r r )r r r r r � set_result: r zFuture.set_resultc C r r r )r r r r r � set_exception> r zFuture.set_exceptionr )�__name__� __module__� __qualname__�__doc__�abc�abstractmethodr r r r r r r r r r r r r r s( r )� metaclass)r r �object�ABCMetar r r r r �<module> s __pycache__/polling.cpython-310.pyc 0000644 00000031377 15030317645 0013140 0 ustar 00 o �h 8 � @ s� d Z ddlZddlZddlmZ ddlmZ ddlm Z ddlm Z G dd� de �Z e� e ejejejej�Zejed �Ze� e �Zejed d d d d�ZG dd� de j�ZdS )z5Abstract and helper bases for Future implementations.� N)� exceptions��retry)�_helpers)�basec @ s e Zd ZdZdS )�_OperationNotCompletez-Private exception used for polling via retry.N)�__name__� __module__� __qualname__�__doc__� r r �Q/usr/local/CyberCP/lib/python3.10/site-packages/google/api_core/future/polling.pyr s r )� predicateg �?g 4@g �?i� )r �initial�maximum� multiplier�timeoutc s� e Zd ZdZe� Zef� fdd� Zej ddd��Z ddd�Z d d � Z eddfd d �Z eddfd d�Zefdd�Zdd� Zdd� Zdd� Zdd� Z� ZS )� PollingFuturea� A Future that needs to poll some service to check its status. The :meth:`done` method should be implemented by subclasses. The polling behavior will repeatedly call ``done`` until it returns True. The actual polling logic is encapsulated in :meth:`result` method. See documentation for that method for details on how polling works. .. note:: Privacy here is intended to prevent the final class from overexposing, not to prevent subclasses from accessing methods. Args: 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 :meth:`result` method it will override the ``polling.timeout`` property. retry (google.api_core.retry.Retry): DEPRECATED use ``polling`` instead. If set, it will override ``polling`` parameter for backward compatibility. c s@ t t| ��� |�d|�| _d | _d | _d| _ d | _g | _ d S )Nr F) �superr �__init__�get�_polling�_result� _exception� _result_set�_polling_thread�_done_callbacks)�self�polling�kwargs�� __class__r r r [ s zPollingFuture.__init__Nc C s t � �)a{ Checks to see if the operation is complete. Args: retry (google.api_core.retry.Retry): (Optional) How to retry the polling RPC (to not be confused with polling configuration. See the documentation for :meth:`result` for details). Returns: bool: True if the operation is complete, False otherwise. )�NotImplementedError�r r r r r �donef s zPollingFuture.donec C s | j |d�s t� �dS )z2Check if the future is done and raise if it's not.r N)r$ r r# r r r �_done_or_raiseu s �z PollingFuture._done_or_raisec C s | � � S )z+True if the operation is currently running.)r$ )r r r r �runningz s zPollingFuture.runningc C sf | j rdS |p | j}|tjur|�|�}z || j�|d� W dS tjy2 tj � d|j � d���w )z,Poll and wait for the Future to be resolved.Nr z<Operation did not complete within the designated timeout of z seconds.) r r r �_DEFAULT_VALUE� with_timeoutr% r � RetryError� concurrent�futures� TimeoutErrorr �r r r r r r r �_blocking_poll~ s ���z PollingFuture._blocking_pollc C s& | j |||d� | jdur| j�| jS )a& Get the result of the operation. This method will poll for operation status periodically, blocking if necessary. If you just want to make sure that this method does not block for more than X seconds and you do not care about the nitty-gritty of how this method operates, just call it with ``result(timeout=X)``. The other parameters are for advanced use only. Every call to this method is controlled by the following three parameters, each of which has a specific, distinct role, even though all three may look very similar: ``timeout``, ``retry`` and ``polling``. In most cases users do not need to specify any custom values for any of these parameters and may simply rely on default ones instead. If you choose to specify custom parameters, please make sure you've read the documentation below carefully. First, please check :class:`google.api_core.retry.Retry` class documentation for the proper definition of timeout and deadline terms and for the definition the three different types of timeouts. This class operates in terms of Retry Timeout and Polling Timeout. It does not let customizing RPC timeout and the user is expected to rely on default behavior for it. The roles of each argument of this method are as follows: ``timeout`` (int): (Optional) The Polling Timeout as defined in :class:`google.api_core.retry.Retry`. If the operation does not complete within this timeout an exception will be thrown. This parameter affects neither Retry Timeout nor RPC Timeout. ``retry`` (google.api_core.retry.Retry): (Optional) How to retry the polling RPC. The ``retry.timeout`` property of this parameter is the Retry Timeout as defined in :class:`google.api_core.retry.Retry`. This parameter defines ONLY how the polling RPC call is retried (i.e. what to do if the RPC we used for polling returned an error). It does NOT define how the polling is done (i.e. how frequently and for how long to call the polling RPC); use the ``polling`` parameter for that. If a polling RPC throws and error and retrying it fails, the whole future fails with the corresponding exception. If you want to tune which server response error codes are not fatal for operation polling, use this parameter to control that (``retry.predicate`` in particular). ``polling`` (google.api_core.retry.Retry): (Optional) How often and for how long to call the polling RPC periodically (i.e. what to do if a polling rpc returned successfully but its returned result indicates that the long running operation is not completed yet, so we need to check it again at some point in future). This parameter does NOT define how to retry each individual polling RPC in case of an error; use the ``retry`` parameter for that. The ``polling.timeout`` of this parameter is Polling Timeout as defined in as defined in :class:`google.api_core.retry.Retry`. For each of the arguments, there are also default values in place, which will be used if a user does not specify their own. The default values for the three parameters are not to be confused with the default values for the corresponding arguments in this method (those serve as "not set" markers for the resolution logic). If ``timeout`` is provided (i.e.``timeout is not _DEFAULT VALUE``; note the ``None`` value means "infinite timeout"), it will be used to control the actual Polling Timeout. Otherwise, the ``polling.timeout`` value will be used instead (see below for how the ``polling`` config itself gets resolved). In other words, this parameter effectively overrides the ``polling.timeout`` value if specified. This is so to preserve backward compatibility. If ``retry`` is provided (i.e. ``retry is not None``) it will be used to control retry behavior for the polling RPC and the ``retry.timeout`` will determine the Retry Timeout. If not provided, the polling RPC will be called with whichever default retry config was specified for the polling RPC at the moment of the construction of the polling RPC's client. For example, if the polling RPC is ``operations_client.get_operation()``, the ``retry`` parameter will be controlling its retry behavior (not polling behavior) and, if not specified, that specific method (``operations_client.get_operation()``) will be retried according to the default retry config provided during creation of ``operations_client`` client instead. This argument exists mainly for backward compatibility; users are very unlikely to ever need to set this parameter explicitly. If ``polling`` is provided (i.e. ``polling is not None``), it will be used to control the overall polling behavior and ``polling.timeout`` will control Polling Timeout unless it is overridden by ``timeout`` parameter as described above. If not provided, the``polling`` parameter specified during construction of this future (the ``polling`` argument in the constructor) will be used instead. Note: since the ``timeout`` argument may override ``polling.timeout`` value, this parameter should be viewed as coupled with the ``timeout`` parameter as described above. Args: timeout (int): (Optional) How long (in seconds) to wait for the operation to complete. If None, wait indefinitely. retry (google.api_core.retry.Retry): (Optional) How to retry the polling RPC. This defines ONLY how the polling RPC call is retried (i.e. what to do if the RPC we used for polling returned an error). It does NOT define how the polling is done (i.e. how frequently and for how long to call the polling RPC). polling (google.api_core.retry.Retry): (Optional) How often and for how long to call polling RPC periodically. This parameter does NOT define how to retry each individual polling RPC call (use the ``retry`` parameter for that). Returns: google.protobuf.Message: The Operation's result. Raises: google.api_core.GoogleAPICallError: If the operation errors or if the timeout is reached before the operation completes. )r r r N)r. r r r- r r r �result� s p zPollingFuture.resultc C s | j |d� | jS )a� Get the exception from the operation, blocking if necessary. See the documentation for the :meth:`result` method for details on how this method operates, as both ``result`` and this method rely on the exact same polling logic. The only difference is that this method does not accept ``retry`` and ``polling`` arguments but relies on the default ones instead. Args: timeout (int): How long to wait for the operation to complete. If None, wait indefinitely. Returns: Optional[google.api_core.GoogleAPICallError]: The operation's error. )r )r. r )r r r r r � exception s zPollingFuture.exceptionc C sD | j r t�|| � dS | j�|� | jdu r tj| jd�| _dS dS )aV Add a callback to be executed when the operation is complete. If the operation is not already complete, this will start a helper thread to poll for the status of the operation in the background. Args: fn (Callable[Future]): The callback to execute when the operation is complete. N)�target)r r �safe_invoke_callbackr �appendr �start_daemon_threadr. )r �fnr r r �add_done_callback s ��z PollingFuture.add_done_callbackc O s( | j D ]}tj|g|�R i |�� qdS )zInvoke all done callbacks.N)r r r2 )r �argsr �callbackr r r �_invoke_callbacks4 s �z PollingFuture._invoke_callbacksc C � || _ d| _| �| � dS )zSet the Future's result.TN)r r r9 )r r/ r r r � set_result9 � zPollingFuture.set_resultc C r: )zSet the Future's exception.TN)r r r9 )r r0 r r r � set_exception? r< zPollingFuture.set_exception)N)r r r r �objectr' �DEFAULT_POLLINGr �abc�abstractmethodr$ r% r& r. r/ r0 r6 r9 r; r= � __classcell__r r r r r A s yr )r r@ �concurrent.futuresr* �google.api_corer r �retries�google.api_core.futurer r � Exceptionr �if_exception_type�TooManyRequests�InternalServerError� BadGateway�ServiceUnavailable�RETRY_PREDICATE�Retry� DEFAULT_RETRY�POLLING_PREDICATEr? �Futurer r r r r �<module> s6 � �� __pycache__/_helpers.cpython-310.pyc 0000644 00000001525 15030317645 0013265 0 ustar 00 o �h� � @ s2 d Z ddlZddlZe�e�Zdd� Zdd� ZdS )z Private helpers for futures.� Nc O s" t j| i |��}d|_|�� |S )z0Starts a thread and marks it as a daemon thread.T)� threading�Thread�daemon�start)�args�kwargs�thread� r �R/usr/local/CyberCP/lib/python3.10/site-packages/google/api_core/future/_helpers.py�start_daemon_thread s r c O s0 z| |i |��W S t y t�d� Y dS w )z9Invoke a callback, swallowing and logging any exceptions.z&Error while executing Future callback.N)� Exception�_LOGGER� exception)�callbackr r r r r �safe_invoke_callback s �r )�__doc__�loggingr � getLogger�__name__r r r r r r r �<module> s polling.py 0000644 00000034015 15030317645 0006571 0 ustar 00 # Copyright 2017, Google LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. """Abstract and helper bases for Future implementations.""" import abc import concurrent.futures from google.api_core import exceptions from google.api_core import retry as retries from google.api_core.future import _helpers from google.api_core.future import base class _OperationNotComplete(Exception): """Private exception used for polling via retry.""" pass # DEPRECATED as it conflates RPC retry and polling concepts into one. # Use POLLING_PREDICATE instead to configure polling. RETRY_PREDICATE = retries.if_exception_type( _OperationNotComplete, exceptions.TooManyRequests, exceptions.InternalServerError, exceptions.BadGateway, exceptions.ServiceUnavailable, ) # DEPRECATED: use DEFAULT_POLLING to configure LRO polling logic. Construct # Retry object using its default values as a baseline for any custom retry logic # (not to be confused with polling logic). DEFAULT_RETRY = retries.Retry(predicate=RETRY_PREDICATE) # POLLING_PREDICATE is supposed to poll only on _OperationNotComplete. # Any RPC-specific errors (like ServiceUnavailable) will be handled # by retry logic (not to be confused with polling logic) which is triggered for # every polling RPC independently of polling logic but within its context. POLLING_PREDICATE = retries.if_exception_type( _OperationNotComplete, ) # Default polling configuration DEFAULT_POLLING = retries.Retry( predicate=POLLING_PREDICATE, initial=1.0, # seconds maximum=20.0, # seconds multiplier=1.5, timeout=900, # seconds ) class PollingFuture(base.Future): """A Future that needs to poll some service to check its status. The :meth:`done` method should be implemented by subclasses. The polling behavior will repeatedly call ``done`` until it returns True. The actual polling logic is encapsulated in :meth:`result` method. See documentation for that method for details on how polling works. .. note:: Privacy here is intended to prevent the final class from overexposing, not to prevent subclasses from accessing methods. Args: 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 :meth:`result` method it will override the ``polling.timeout`` property. retry (google.api_core.retry.Retry): DEPRECATED use ``polling`` instead. If set, it will override ``polling`` parameter for backward compatibility. """ _DEFAULT_VALUE = object() def __init__(self, polling=DEFAULT_POLLING, **kwargs): super(PollingFuture, self).__init__() self._polling = kwargs.get("retry", polling) self._result = None self._exception = None self._result_set = False """bool: Set to True when the result has been set via set_result or set_exception.""" self._polling_thread = None self._done_callbacks = [] @abc.abstractmethod def done(self, retry=None): """Checks to see if the operation is complete. Args: retry (google.api_core.retry.Retry): (Optional) How to retry the polling RPC (to not be confused with polling configuration. See the documentation for :meth:`result` for details). Returns: bool: True if the operation is complete, False otherwise. """ # pylint: disable=redundant-returns-doc, missing-raises-doc raise NotImplementedError() def _done_or_raise(self, retry=None): """Check if the future is done and raise if it's not.""" if not self.done(retry=retry): raise _OperationNotComplete() def running(self): """True if the operation is currently running.""" return not self.done() def _blocking_poll(self, timeout=_DEFAULT_VALUE, retry=None, polling=None): """Poll and wait for the Future to be resolved.""" if self._result_set: return polling = polling or self._polling if timeout is not PollingFuture._DEFAULT_VALUE: polling = polling.with_timeout(timeout) try: polling(self._done_or_raise)(retry=retry) except exceptions.RetryError: raise concurrent.futures.TimeoutError( f"Operation did not complete within the designated timeout of " f"{polling.timeout} seconds." ) def result(self, timeout=_DEFAULT_VALUE, retry=None, polling=None): """Get the result of the operation. This method will poll for operation status periodically, blocking if necessary. If you just want to make sure that this method does not block for more than X seconds and you do not care about the nitty-gritty of how this method operates, just call it with ``result(timeout=X)``. The other parameters are for advanced use only. Every call to this method is controlled by the following three parameters, each of which has a specific, distinct role, even though all three may look very similar: ``timeout``, ``retry`` and ``polling``. In most cases users do not need to specify any custom values for any of these parameters and may simply rely on default ones instead. If you choose to specify custom parameters, please make sure you've read the documentation below carefully. First, please check :class:`google.api_core.retry.Retry` class documentation for the proper definition of timeout and deadline terms and for the definition the three different types of timeouts. This class operates in terms of Retry Timeout and Polling Timeout. It does not let customizing RPC timeout and the user is expected to rely on default behavior for it. The roles of each argument of this method are as follows: ``timeout`` (int): (Optional) The Polling Timeout as defined in :class:`google.api_core.retry.Retry`. If the operation does not complete within this timeout an exception will be thrown. This parameter affects neither Retry Timeout nor RPC Timeout. ``retry`` (google.api_core.retry.Retry): (Optional) How to retry the polling RPC. The ``retry.timeout`` property of this parameter is the Retry Timeout as defined in :class:`google.api_core.retry.Retry`. This parameter defines ONLY how the polling RPC call is retried (i.e. what to do if the RPC we used for polling returned an error). It does NOT define how the polling is done (i.e. how frequently and for how long to call the polling RPC); use the ``polling`` parameter for that. If a polling RPC throws and error and retrying it fails, the whole future fails with the corresponding exception. If you want to tune which server response error codes are not fatal for operation polling, use this parameter to control that (``retry.predicate`` in particular). ``polling`` (google.api_core.retry.Retry): (Optional) How often and for how long to call the polling RPC periodically (i.e. what to do if a polling rpc returned successfully but its returned result indicates that the long running operation is not completed yet, so we need to check it again at some point in future). This parameter does NOT define how to retry each individual polling RPC in case of an error; use the ``retry`` parameter for that. The ``polling.timeout`` of this parameter is Polling Timeout as defined in as defined in :class:`google.api_core.retry.Retry`. For each of the arguments, there are also default values in place, which will be used if a user does not specify their own. The default values for the three parameters are not to be confused with the default values for the corresponding arguments in this method (those serve as "not set" markers for the resolution logic). If ``timeout`` is provided (i.e.``timeout is not _DEFAULT VALUE``; note the ``None`` value means "infinite timeout"), it will be used to control the actual Polling Timeout. Otherwise, the ``polling.timeout`` value will be used instead (see below for how the ``polling`` config itself gets resolved). In other words, this parameter effectively overrides the ``polling.timeout`` value if specified. This is so to preserve backward compatibility. If ``retry`` is provided (i.e. ``retry is not None``) it will be used to control retry behavior for the polling RPC and the ``retry.timeout`` will determine the Retry Timeout. If not provided, the polling RPC will be called with whichever default retry config was specified for the polling RPC at the moment of the construction of the polling RPC's client. For example, if the polling RPC is ``operations_client.get_operation()``, the ``retry`` parameter will be controlling its retry behavior (not polling behavior) and, if not specified, that specific method (``operations_client.get_operation()``) will be retried according to the default retry config provided during creation of ``operations_client`` client instead. This argument exists mainly for backward compatibility; users are very unlikely to ever need to set this parameter explicitly. If ``polling`` is provided (i.e. ``polling is not None``), it will be used to control the overall polling behavior and ``polling.timeout`` will control Polling Timeout unless it is overridden by ``timeout`` parameter as described above. If not provided, the``polling`` parameter specified during construction of this future (the ``polling`` argument in the constructor) will be used instead. Note: since the ``timeout`` argument may override ``polling.timeout`` value, this parameter should be viewed as coupled with the ``timeout`` parameter as described above. Args: timeout (int): (Optional) How long (in seconds) to wait for the operation to complete. If None, wait indefinitely. retry (google.api_core.retry.Retry): (Optional) How to retry the polling RPC. This defines ONLY how the polling RPC call is retried (i.e. what to do if the RPC we used for polling returned an error). It does NOT define how the polling is done (i.e. how frequently and for how long to call the polling RPC). polling (google.api_core.retry.Retry): (Optional) How often and for how long to call polling RPC periodically. This parameter does NOT define how to retry each individual polling RPC call (use the ``retry`` parameter for that). Returns: google.protobuf.Message: The Operation's result. Raises: google.api_core.GoogleAPICallError: If the operation errors or if the timeout is reached before the operation completes. """ self._blocking_poll(timeout=timeout, retry=retry, polling=polling) if self._exception is not None: # pylint: disable=raising-bad-type # Pylint doesn't recognize that this is valid in this case. raise self._exception return self._result def exception(self, timeout=_DEFAULT_VALUE): """Get the exception from the operation, blocking if necessary. See the documentation for the :meth:`result` method for details on how this method operates, as both ``result`` and this method rely on the exact same polling logic. The only difference is that this method does not accept ``retry`` and ``polling`` arguments but relies on the default ones instead. Args: timeout (int): How long to wait for the operation to complete. If None, wait indefinitely. Returns: Optional[google.api_core.GoogleAPICallError]: The operation's error. """ self._blocking_poll(timeout=timeout) return self._exception def add_done_callback(self, fn): """Add a callback to be executed when the operation is complete. If the operation is not already complete, this will start a helper thread to poll for the status of the operation in the background. Args: fn (Callable[Future]): The callback to execute when the operation is complete. """ if self._result_set: _helpers.safe_invoke_callback(fn, self) return self._done_callbacks.append(fn) if self._polling_thread is None: # The polling thread will exit on its own as soon as the operation # is done. self._polling_thread = _helpers.start_daemon_thread( target=self._blocking_poll ) def _invoke_callbacks(self, *args, **kwargs): """Invoke all done callbacks.""" for callback in self._done_callbacks: _helpers.safe_invoke_callback(callback, *args, **kwargs) def set_result(self, result): """Set the Future's result.""" self._result = result self._result_set = True self._invoke_callbacks(self) def set_exception(self, exception): """Set the Future's exception.""" self._exception = exception self._result_set = True self._invoke_callbacks(self) __init__.py 0000644 00000001276 15030317645 0006667 0 ustar 00 # Copyright 2017, Google LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. """Futures for dealing with asynchronous operations.""" from google.api_core.future.base import Future __all__ = ["Future"]
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.03 |
proxy
|
phpinfo
|
Settings