args = (resource_names: "projects/precise-truck-742"
filter: "timestamp>=\"2022-11-07T20:20:17.862870+0000\" AND logName=proj...AiB0aWbBhDws7mbAyIMCP-YqJsGEP-T69wDUNjXoeDZ9LqEsAFSBwjK3bCwgR9g0oLQ44-S96OZAWobCgwIgNelmwYQq7rvrgMSBwgHEP_LkgcYACAA"
,)
kwargs = {'metadata': (), 'timeout': 60.0}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:


      return callable_(*args, **kwargs)


.nox/system-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:72:

self = <grpc._channel._UnaryUnaryMultiCallable object at 0x7f4f473c3910>

request = resource_names: "projects/precise-truck-742"

filter: "timestamp>="2022-11-07T20:20:17.862870+0000" AND logName=proje...aDAiB0aWbBhDws7mbAyIMCP-YqJsGEP-T69wDUNjXoeDZ9LqEsAFSBwjK3bCwgR9g0oLQ44-S96OZAWobCgwIgNelmwYQq7rvrgMSBwgHEP_LkgcYACAA"
timeout = 60.0, metadata = (), credentials = None, wait_for_ready = None

compression = None
def __call__(self,
             request,
             timeout=None,
             metadata=None,
             credentials=None,
             wait_for_ready=None,
             compression=None):
    state, call, = self._blocking(request, timeout, metadata, credentials,
                                  wait_for_ready, compression)


  return _end_unary_response_blocking(state, call, False, None)


.nox/system-3-8/lib/python3.8/site-packages/grpc/_channel.py:946:

state = <grpc._channel._RPCState object at 0x7f4f213c3dc0>

call = <grpc._cython.cygrpc.SegregatedCall object at 0x7f4f213acbc0>

with_call = False, deadline = None
def _end_unary_response_blocking(state, call, with_call, deadline):
    if state.code is grpc.StatusCode.OK:
        if with_call:
            rendezvous = _MultiThreadedRendezvous(state, call, None, deadline)
            return state.response, rendezvous
        else:
            return state.response
    else:


      raise _InactiveRpcError(state)


E           grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:

E           	status = StatusCode.CANCELLED

E           	details = "The operation was cancelled."

E           	debug_error_string = "UNKNOWN:Error received from peer ipv4:216.239.32.174:443 {grpc_message:"The operation was cancelled.", grpc_status:1, created_time:"2022-11-07T20:33:13.87007583+00:00"}"

E           >
.nox/system-3-8/lib/python3.8/site-packages/grpc/_channel.py:849: _InactiveRpcError
The above exception was the direct cause of the following exception:
self = <test_system.TestLogging testMethod=test_log_handler_async>
def test_log_handler_async(self):
    LOG_MESSAGE = "It was the worst of times"

    handler_name = self._logger_name("handler_async")
    handler = CloudLoggingHandler(Config.CLIENT, name=handler_name)
    # only create the logger to delete, hidden otherwise
    logger = Config.CLIENT.logger(handler_name)
    self.to_delete.append(logger)

    cloud_logger = logging.getLogger(handler.name)
    cloud_logger.addHandler(handler)
    cloud_logger.warning(LOG_MESSAGE)
    handler.flush()


  entries = _list_entries(logger)


tests/system/test_system.py:549:

tests/system/test_system.py:86: in _list_entries

return outer(logger)

.nox/system-3-8/lib/python3.8/site-packages/test_utils/retry.py:100: in wrapped_function

return to_wrap(*args, **kwargs)

.nox/system-3-8/lib/python3.8/site-packages/test_utils/retry.py:157: in wrapped_function

result = to_wrap(*args, **kwargs)

tests/system/test_system.py:64: in consume_entries

return list(logger.list_entries(filter=_time_filter))

google/cloud/logging_v2/_gapic.py:108: in log_entries_pager

for entry in log_iter:

google/cloud/logging_v2/services/logging_service_v2/pagers.py:87: in iter

for page in self.pages:

google/cloud/logging_v2/services/logging_service_v2/pagers.py:83: in pages

self._response = self._method(self._request, metadata=self._metadata)

.nox/system-3-8/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py:154: in call

return wrapped_func(*args, **kwargs)

.nox/system-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283: in retry_wrapped_func

return retry_target(

.nox/system-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190: in retry_target

return target()

.nox/system-3-8/lib/python3.8/site-packages/google/api_core/timeout.py:99: in func_with_timeout

return func(*args, **kwargs)

args = (resource_names: "projects/precise-truck-742"

filter: "timestamp>="2022-11-07T20:20:17.862870+0000" AND logName=proj...AiB0aWbBhDws7mbAyIMCP-YqJsGEP-T69wDUNjXoeDZ9LqEsAFSBwjK3bCwgR9g0oLQ44-S96OZAWobCgwIgNelmwYQq7rvrgMSBwgHEP_LkgcYACAA"

,)

kwargs = {'metadata': (), 'timeout': 60.0}
@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
    try:
        return callable_(*args, **kwargs)
    except grpc.RpcError as exc:


      raise exceptions.from_grpc_error(exc) from exc


E           google.api_core.exceptions.Cancelled: 499 The operation was cancelled.
.nox/system-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:74: Cancelled