Warning: Permanently added 'localhost' (ED25519) to the list of known hosts.
Warning: Permanently added 'localhost' (ED25519) to the list of known hosts.
Warning: Permanently added 'localhost' (ED25519) to the list of known hosts.
[20:28:28] Transferring environment variable script to build VM
[20:28:29] Transferring kokoro_log_reader.py to build VM
[20:28:31] Transferring source code to build VM
[20:28:35] Executing build script on build VM



[ID: 7559003] Executing command via SSH:
export KOKORO_BUILD_NUMBER="107"
export KOKORO_JOB_NAME="cloud-devrel/client-libraries/python/googleapis/python-bigtable/continuous/prerelease-deps"
source /tmpfs/kokoro-env_vars.sh; cd /tmpfs/src/ ; chmod 755 github/python-bigtable/.kokoro/trampoline.sh ; PYTHON_3_VERSION="$(pyenv which python3 2> /dev/null || which python3)" ; PYTHON_2_VERSION="$(pyenv which python2 2> /dev/null || which python2)" ; if "$PYTHON_3_VERSION" -c "import psutil" ; then KOKORO_PYTHON_COMMAND="$PYTHON_3_VERSION" ; else KOKORO_PYTHON_COMMAND="$PYTHON_2_VERSION" ; fi > /dev/null 2>&1 ; echo "export KOKORO_PYTHON_COMMAND="$KOKORO_PYTHON_COMMAND"" > "$HOME/.kokoro_python_vars" ; nohup bash -c "( rm -f /tmpfs/kokoro_build_exit_code ; github/python-bigtable/.kokoro/trampoline.sh ; echo \${PIPESTATUS[0]} > /tmpfs/kokoro_build_exit_code ) > /tmpfs/kokoro_build.log 2>&1" > /dev/null 2>&1 & echo $! > /tmpfs/kokoro_build.pid ; source "$HOME/.kokoro_python_vars" ; "$KOKORO_PYTHON_COMMAND" /tmpfs/kokoro_log_reader.py /tmpfs/kokoro_build.log /tmpfs/kokoro_build_exit_code /tmpfs/kokoro_build.pid /tmpfs/kokoro_log_reader.pid --start_byte 0

2022-09-01 20:28:36 Creating folder on disk for secrets: /tmpfs/src/gfile/secret_manager
Activated service account credentials for: [kokoro-trampoline@cloud-devrel-kokoro-resources.iam.gserviceaccount.com]
WARNING: Your config file at [/home/kbuilder/.docker/config.json] contains these credential helper entries:

{
"credHelpers": {
"gcr.io": "gcr",
"us.gcr.io": "gcr",
"asia.gcr.io": "gcr",
"staging-k8s.gcr.io": "gcr",
"eu.gcr.io": "gcr"
}
}
These will be overwritten.
Docker configuration file updated.
Using default tag: latest
latest: Pulling from cloud-devrel-kokoro-resources/python-multi
3b65ec22a9e9: Pulling fs layer
69c5366ea44f: Pulling fs layer
ff37eb970fa5: Pulling fs layer
60bd1a8d0723: Pulling fs layer
e1626803c079: Pulling fs layer
7c0dc38a98d3: Pulling fs layer
77257256cf91: Pulling fs layer
36b4ee5f747d: Pulling fs layer
4b5bd633e88c: Pulling fs layer
5ee8c5d191b9: Pulling fs layer
d17c740ce06a: Pulling fs layer
6c2bc7d44d6a: Pulling fs layer
5f88b2d437a9: Pulling fs layer
78e90acc669f: Pulling fs layer
6f8351dc4fc3: Pulling fs layer
265f27c75e2f: Pulling fs layer
f7f53b411e60: Pulling fs layer
b0cb88ab437c: Pulling fs layer
5766dcf37093: Pulling fs layer
48ae7f021f5c: Pulling fs layer
60bd1a8d0723: Waiting
e1626803c079: Waiting
7c0dc38a98d3: Waiting
77257256cf91: Waiting
36b4ee5f747d: Waiting
4b5bd633e88c: Waiting
6c2bc7d44d6a: Waiting
5ee8c5d191b9: Waiting
d17c740ce06a: Waiting
f7f53b411e60: Waiting
5f88b2d437a9: Waiting
6f8351dc4fc3: Waiting
265f27c75e2f: Waiting
78e90acc669f: Waiting
b0cb88ab437c: Waiting
5766dcf37093: Waiting
48ae7f021f5c: Waiting
ff37eb970fa5: Verifying Checksum
ff37eb970fa5: Download complete
60bd1a8d0723: Verifying Checksum
60bd1a8d0723: Download complete
e1626803c079: Verifying Checksum
e1626803c079: Download complete
3b65ec22a9e9: Verifying Checksum
3b65ec22a9e9: Download complete
7c0dc38a98d3: Verifying Checksum
7c0dc38a98d3: Download complete
36b4ee5f747d: Verifying Checksum
36b4ee5f747d: Download complete
69c5366ea44f: Verifying Checksum
69c5366ea44f: Download complete
77257256cf91: Verifying Checksum
77257256cf91: Download complete
5ee8c5d191b9: Verifying Checksum
5ee8c5d191b9: Download complete
d17c740ce06a: Verifying Checksum
d17c740ce06a: Download complete
3b65ec22a9e9: Pull complete
5f88b2d437a9: Verifying Checksum
5f88b2d437a9: Download complete
6c2bc7d44d6a: Download complete
78e90acc669f: Verifying Checksum
78e90acc669f: Download complete
6f8351dc4fc3: Verifying Checksum
6f8351dc4fc3: Download complete
265f27c75e2f: Verifying Checksum
265f27c75e2f: Download complete
4b5bd633e88c: Verifying Checksum
4b5bd633e88c: Download complete
f7f53b411e60: Verifying Checksum
f7f53b411e60: Download complete
b0cb88ab437c: Verifying Checksum
b0cb88ab437c: Download complete
5766dcf37093: Verifying Checksum
5766dcf37093: Download complete
48ae7f021f5c: Verifying Checksum
48ae7f021f5c: Download complete
69c5366ea44f: Pull complete
ff37eb970fa5: Pull complete
60bd1a8d0723: Pull complete
e1626803c079: Pull complete
7c0dc38a98d3: Pull complete
77257256cf91: Pull complete
36b4ee5f747d: Pull complete
4b5bd633e88c: Pull complete
5ee8c5d191b9: Pull complete
d17c740ce06a: Pull complete
6c2bc7d44d6a: Pull complete
5f88b2d437a9: Pull complete
78e90acc669f: Pull complete
6f8351dc4fc3: Pull complete
265f27c75e2f: Pull complete
f7f53b411e60: Pull complete
b0cb88ab437c: Pull complete
5766dcf37093: Pull complete
48ae7f021f5c: Pull complete
Digest: sha256:f6b0315aa551c5ff46f4ca93602ea4f122526d264f8bdcb631f3b594dd073b96
Status: Downloaded newer image for gcr.io/cloud-devrel-kokoro-resources/python-multi:latest
gcr.io/cloud-devrel-kokoro-resources/python-multi:latest
Executing: docker run --rm --interactive --network=host --privileged --volume=/var/run/docker.sock:/var/run/docker.sock --workdir=/tmpfs/src --entrypoint=github/python-bigtable/.kokoro/build.sh --env-file=/tmpfs/tmp/tmp4h5i6swj/envfile --volume=/tmpfs:/tmpfs gcr.io/cloud-devrel-kokoro-resources/python-multi
KOKORO_KEYSTORE_DIR=/tmpfs/src/keystore
KOKORO_GITHUB_COMMIT_URL=https://github.com/googleapis/python-bigtable/commit/49b780d1816df9a83ba0748e33edb1f6b6543758
KOKORO_JOB_NAME=cloud-devrel/client-libraries/python/googleapis/python-bigtable/continuous/prerelease-deps
KOKORO_GIT_COMMIT=49b780d1816df9a83ba0748e33edb1f6b6543758
KOKORO_JOB_CLUSTER=GCP_UBUNTU
KOKORO_BLAZE_DIR=/tmpfs/src/objfs
KOKORO_ROOT=/tmpfs
KOKORO_JOB_TYPE=CONTINUOUS_INTEGRATION
KOKORO_BUILD_NUMBER=107
KOKORO_JOB_POOL=yoshi-ubuntu
KOKORO_GITHUB_COMMIT=49b780d1816df9a83ba0748e33edb1f6b6543758
KOKORO_BUILD_INITIATOR=kokoro
KOKORO_ARTIFACTS_DIR=/tmpfs/src
KOKORO_BUILD_ID=91559462-229d-46fa-b3b3-85675b37133c
KOKORO_GFILE_DIR=/tmpfs/src/gfile
KOKORO_POSIX_ROOT=/tmpfs
KOKORO_BUILD_ARTIFACTS_SUBDIR=prod/cloud-devrel/client-libraries/python/googleapis/python-bigtable/continuous/prerelease-deps/107/20220901-202712
WARNING: Skipping nox-automation as it is not installed.
WARNING: You are using pip version 22.0.4; however, version 22.2.2 is available.
You should consider upgrading via the '/venv/bin/python3 -m pip install --upgrade pip' command.
2022.8.7
nox > Running session prerelease_deps-3.8
nox > Creating virtual environment (virtualenv) using python3.8 in .nox/prerelease_deps-3-8
nox > python -m pip install -e '.[all, tests, tracing]'
nox > python -m pip install mock asyncmock pytest pytest-cov pytest-asyncio
nox > python -m pip install mock pytest google-cloud-testutils
nox > python -m pip install google-api-core google-cloud-core grpc-google-iam-v1 proto-plus libcst protobuf
nox > python -m pip install --pre --no-deps --upgrade protobuf
nox > python -m pip install --pre --no-deps --upgrade six
nox > python -m pip install --pre --no-deps --upgrade googleapis-common-protos
nox > python -m pip install --pre --no-deps --upgrade grpcio
nox > python -m pip install --pre --no-deps --upgrade grpcio-status
nox > python -m pip install --pre --no-deps --upgrade google-api-core
nox > python -m pip install --pre --no-deps --upgrade proto-plus
nox > python -m pip install --pre --no-deps --upgrade google-cloud-testutils
nox > python -m pip install --pre --no-deps --upgrade click
nox > python -m pip install requests google-auth
nox > python -c 'import google.protobuf; print(google.protobuf.__version__)'
4.21.5
nox > python -c 'import grpc; print(grpc.__version__)'
1.49.0rc3
nox > py.test tests/unit
============================= test session starts ==============================
platform linux -- Python 3.8.13, pytest-7.1.2, pluggy-1.0.0
rootdir: /tmpfs/src/github/python-bigtable
plugins: cov-3.0.0, asyncio-0.19.0
asyncio: mode=strict
collected 1431 items

tests/unit/test_app_profile.py ........................ [ 1%]
tests/unit/test_backup.py .............................................. [ 4%]
.. [ 5%]
tests/unit/test_batcher.py ........ [ 5%]
tests/unit/test_client.py ...................................... [ 8%]
tests/unit/test_cluster.py .............................. [ 10%]
tests/unit/test_column_family.py ....................................... [ 13%]
[ 13%]
tests/unit/test_encryption_info.py .............. [ 14%]
tests/unit/test_error.py ........... [ 14%]
tests/unit/test_instance.py ..................................... [ 17%]
tests/unit/test_policy.py ................ [ 18%]
tests/unit/test_row.py ...................................... [ 21%]
tests/unit/test_row_data.py ............................................ [ 24%]
...................... [ 25%]
tests/unit/test_row_filters.py ......................................... [ 28%]
.................................................. [ 32%]
tests/unit/test_row_merger.py .......................................... [ 35%]
.............. [ 36%]
tests/unit/test_row_set.py ....................... [ 37%]
tests/unit/test_table.py ............................................... [ 40%]
.......................................... [ 43%]
tests/unit/gapic/bigtable_admin_v2/test_bigtable_instance_admin.py ..... [ 44%]
........................................................................ [ 49%]
........................................................................ [ 54%]
........................................................................ [ 59%]
........................................................................ [ 64%]
........................ [ 66%]
tests/unit/gapic/bigtable_admin_v2/test_bigtable_table_admin.py ........ [ 66%]
........................................................................ [ 71%]
........................................................................ [ 76%]
........................................................................ [ 81%]
........................................................................ [ 86%]
............................................... [ 90%]
tests/unit/gapic/bigtable_v2/test_bigtable.py .......................... [ 91%]
........................................................................ [ 96%]
............................................. [100%]

=============================== warnings summary ===============================
tests/unit/test_row_data.py::test_partial_rows_data_state_start
/tmpfs/src/github/python-bigtable/tests/unit/test_row_data.py:508: DeprecationWarning: `PartialRowsData#state()` is deprecated and will be removed in the future
assert yrd.state == yrd.NEW_ROW

tests/unit/test_row_data.py::test_partial_rows_data_state_new_row_w_row
/tmpfs/src/github/python-bigtable/tests/unit/test_row_data.py:543: DeprecationWarning: `PartialRowsData#state()` is deprecated and will be removed in the future
assert yrd.state == yrd.NEW_ROW

tests/unit/test_row_data.py::test_partial_rows_data_multiple_chunks
/tmpfs/src/github/python-bigtable/tests/unit/test_row_data.py:580: DeprecationWarning: `PartialRowsData#state()` is deprecated and will be removed in the future
assert yrd.state == yrd.NEW_ROW

-- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html
====================== 1431 passed, 3 warnings in 17.76s =======================
nox > py.test --verbose --junitxml=system_3.8_sponge_log.xml tests/system
============================= test session starts ==============================
platform linux -- Python 3.8.13, pytest-7.1.2, pluggy-1.0.0 -- /tmpfs/src/github/python-bigtable/.nox/prerelease_deps-3-8/bin/python
cachedir: .pytest_cache
rootdir: /tmpfs/src/github/python-bigtable
plugins: cov-3.0.0, asyncio-0.19.0
asyncio: mode=strict
collecting ... collected 42 items

tests/system/test_data_api.py::test_table_read_rows_filter_millis ERROR [ 2%]
tests/system/test_data_api.py::test_table_mutate_rows ERROR [ 4%]
tests/system/test_data_api.py::test_table_truncate ERROR [ 7%]
tests/system/test_data_api.py::test_table_drop_by_prefix ERROR [ 9%]
tests/system/test_data_api.py::test_table_read_rows_w_row_set ERROR [ 11%]
tests/system/test_data_api.py::test_rowset_add_row_range_w_pfx ERROR [ 14%]
tests/system/test_data_api.py::test_table_read_row_large_cell ERROR [ 16%]
tests/system/test_data_api.py::test_table_read_row ERROR [ 19%]
tests/system/test_data_api.py::test_table_read_rows ERROR [ 21%]
tests/system/test_data_api.py::test_read_with_label_applied ERROR [ 23%]
tests/system/test_data_api.py::test_access_with_non_admin_client FAILED [ 26%]
tests/system/test_instance_admin.py::test_client_list_instances PASSED [ 28%]
tests/system/test_instance_admin.py::test_instance_exists_hit PASSED [ 30%]
tests/system/test_instance_admin.py::test_instance_exists_miss PASSED [ 33%]
tests/system/test_instance_admin.py::test_instance_reload PASSED [ 35%]
tests/system/test_instance_admin.py::test_instance_create_prod PASSED [ 38%]
tests/system/test_instance_admin.py::test_instance_create_development PASSED [ 40%]
tests/system/test_instance_admin.py::test_instance_create_w_two_clusters PASSED [ 42%]
tests/system/test_instance_admin.py::test_instance_create_app_profile_create_with_multi_cluster_ids FAILED [ 45%]
tests/system/test_instance_admin.py::test_instance_create_w_two_clusters_cmek SKIPPED [ 47%]
tests/system/test_instance_admin.py::test_instance_update_display_name_and_labels PASSED [ 50%]
tests/system/test_instance_admin.py::test_instance_update_w_type PASSED [ 52%]
tests/system/test_instance_admin.py::test_cluster_exists_hit PASSED [ 54%]
tests/system/test_instance_admin.py::test_cluster_exists_miss PASSED [ 57%]
tests/system/test_instance_admin.py::test_cluster_create FAILED [ 59%]
tests/system/test_instance_admin.py::test_cluster_create_w_autoscaling FAILED [ 61%]
tests/system/test_instance_admin.py::test_cluster_update PASSED [ 64%]
tests/system/test_instance_admin.py::test_cluster_update_w_autoscaling PASSED [ 66%]
tests/system/test_instance_admin.py::test_cluster_update_w_autoscaling_partial PASSED [ 69%]
tests/system/test_instance_admin.py::test_cluster_disable_autoscaling PASSED [ 71%]
tests/system/test_table_admin.py::test_instance_list_tables ERROR [ 73%]
tests/system/test_table_admin.py::test_table_exists ERROR [ 76%]
tests/system/test_table_admin.py::test_table_create ERROR [ 78%]
tests/system/test_table_admin.py::test_table_create_w_families ERROR [ 80%]
tests/system/test_table_admin.py::test_table_create_w_split_keys ERROR [ 83%]
tests/system/test_table_admin.py::test_column_family_create ERROR [ 85%]
tests/system/test_table_admin.py::test_column_family_update ERROR [ 88%]
tests/system/test_table_admin.py::test_column_family_delete ERROR [ 90%]
tests/system/test_table_admin.py::test_table_get_iam_policy ERROR [ 92%]
tests/system/test_table_admin.py::test_table_set_iam_policy ERROR [ 95%]
tests/system/test_table_admin.py::test_table_test_iam_permissions ERROR [ 97%]
tests/system/test_table_admin.py::test_table_backup ERROR [100%]

==================================== ERRORS ====================================
_____________ ERROR at setup of test_table_read_rows_filter_millis _____________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
___________________ ERROR at setup of test_table_mutate_rows ___________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
____________________ ERROR at setup of test_table_truncate _____________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_________________ ERROR at setup of test_table_drop_by_prefix __________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_______________ ERROR at setup of test_table_read_rows_w_row_set _______________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
______________ ERROR at setup of test_rowset_add_row_range_w_pfx _______________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_______________ ERROR at setup of test_table_read_row_large_cell _______________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
____________________ ERROR at setup of test_table_read_row _____________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
____________________ ERROR at setup of test_table_read_rows ____________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
________________ ERROR at setup of test_read_with_label_applied ________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_________________ ERROR at setup of test_instance_list_tables __________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_____________________ ERROR at setup of test_table_exists ______________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_____________________ ERROR at setup of test_table_create ______________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
________________ ERROR at setup of test_table_create_w_families ________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_______________ ERROR at setup of test_table_create_w_split_keys _______________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_________________ ERROR at setup of test_column_family_create __________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_________________ ERROR at setup of test_column_family_update __________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_________________ ERROR at setup of test_column_family_delete __________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_________________ ERROR at setup of test_table_get_iam_policy __________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_________________ ERROR at setup of test_table_set_iam_policy __________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
______________ ERROR at setup of test_table_test_iam_permissions _______________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_____________________ ERROR at setup of test_table_backup ______________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 30, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 30.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
data_instance_id = 'g-c-p-d-1662089401116'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
data_cluster_id = 'g-c-p-d-1662089401116-cluster', location_id = 'us-central1-c'
serve_nodes = 3, in_emulator = False

@pytest.fixture(scope="session")
def data_instance_populated(
admin_client,
data_instance_id,
instance_labels,
data_cluster_id,
location_id,
serve_nodes,
in_emulator,
):
instance = admin_client.instance(data_instance_id, labels=instance_labels)
# Emulator does not support instance admin operations (create / delete).
# See: https://cloud.google.com/bigtable/docs/emulator
if not in_emulator:
cluster = instance.cluster(
data_cluster_id,
location_id=location_id,
serve_nodes=serve_nodes,
)
operation = instance.create(clusters=[cluster])
> operation.result(timeout=30)

tests/system/conftest.py:179:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 30, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
=================================== FAILURES ===================================
______________________ test_access_with_non_admin_client _______________________

args = (table_name: "projects/precise-truck-742/instances/g-c-p-d-1662089401116/tables/test-data-api"
rows {
row_keys: "nonesuch"
}
,)
kwargs = {'metadata': [('x-goog-request-params', 'table_name=projects/precise-truck-742/instances/g-c-p-d-1662089401116/tables/test-data-api'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.49.0rc3 gax/2.10.0 gapic/2.11.3')], 'timeout': 61.0}
result = <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.NOT_FOUND
details = "Table not found: pro...nces/g-c-p-d-1662089401116/tables/test-data-api", grpc_status:5, created_time:"2022-09-02T03:30:33.112262448+00:00"}"
>
prefetch_first = True

@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
try:
result = callable_(*args, **kwargs)
# Auto-fetching the first result causes PubSub client's streaming pull
# to hang when re-opening the stream, thus we need examine the hacky
# hidden flag to see if pre-fetching is disabled.
# https://github.com/googleapis/python-pubsub/issues/93#issuecomment-630762257
prefetch_first = getattr(callable_, "_prefetch_first_result_", True)
> return _StreamingResponseIterator(
result, prefetch_first_result=prefetch_first
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:162:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
wrapped = <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.NOT_FOUND
details = "Table not found: pro...nces/g-c-p-d-1662089401116/tables/test-data-api", grpc_status:5, created_time:"2022-09-02T03:30:33.112262448+00:00"}"
>
prefetch_first_result = True

def __init__(self, wrapped, prefetch_first_result=True):
self._wrapped = wrapped

# This iterator is used in a retry context, and returned outside after init.
# gRPC will not throw an exception until the stream is consumed, so we need
# to retrieve the first result, in order to fail, in order to trigger a retry.
try:
if prefetch_first_result:
> self._stored_first_result = next(self._wrapped)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:88:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self = <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.NOT_FOUND
details = "Table not found: pro...nces/g-c-p-d-1662089401116/tables/test-data-api", grpc_status:5, created_time:"2022-09-02T03:30:33.112262448+00:00"}"
>

def __next__(self):
> return self._next()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/grpc/_channel.py:426:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self = <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.NOT_FOUND
details = "Table not found: pro...nces/g-c-p-d-1662089401116/tables/test-data-api", grpc_status:5, created_time:"2022-09-02T03:30:33.112262448+00:00"}"
>

def _next(self):
with self._state.condition:
if self._state.code is None:
event_handler = _event_handler(self._state,
self._response_deserializer)
self._state.due.add(cygrpc.OperationType.receive_message)
operating = self._call.operate(
(cygrpc.ReceiveMessageOperation(_EMPTY_FLAGS),),
event_handler)
if not operating:
self._state.due.remove(cygrpc.OperationType.receive_message)
elif self._state.code is grpc.StatusCode.OK:
raise StopIteration()
else:
raise self

def _response_ready():
return (self._state.response is not None or
(cygrpc.OperationType.receive_message
not in self._state.due and
self._state.code is not None))

_common.wait(self._state.condition.wait, _response_ready)
if self._state.response is not None:
response = self._state.response
self._state.response = None
return response
elif cygrpc.OperationType.receive_message not in self._state.due:
if self._state.code is grpc.StatusCode.OK:
raise StopIteration()
elif self._state.code is not None:
> raise self
E grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
E status = StatusCode.NOT_FOUND
E details = "Table not found: projects/precise-truck-742/instances/g-c-p-d-1662089401116/tables/test-data-api"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:173.194.203.95:443 {grpc_message:"Table not found: projects/precise-truck-742/instances/g-c-p-d-1662089401116/tables/test-data-api", grpc_status:5, created_time:"2022-09-02T03:30:33.112262448+00:00"}"
E >

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/grpc/_channel.py:826: _MultiThreadedRendezvous

The above exception was the direct cause of the following exception:

data_client =
data_instance_id = 'g-c-p-d-1662089401116', data_table_id = 'test-data-api'

def test_access_with_non_admin_client(data_client, data_instance_id, data_table_id):
instance = data_client.instance(data_instance_id)
table = instance.table(data_table_id)
> assert table.read_row("nonesuch") is None # no raise

tests/system/test_data_api.py:383:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
google/cloud/bigtable/table.py:561: in read_row
result_iter = iter(self.read_rows(filter_=filter_, row_set=row_set))
google/cloud/bigtable/table.py:637: in read_rows
return PartialRowsData(data_client.read_rows, request_pb, retry)
google/cloud/bigtable/row_data.py:160: in __init__
self.response_iterator = read_method(request, timeout=self.retry._deadline + 1)
google/cloud/bigtable_v2/services/bigtable/client.py:542: in read_rows
response = rpc(
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py:154: in __call__
return wrapped_func(*args, **kwargs)
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/timeout.py:99: in func_with_timeout
return func(*args, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (table_name: "projects/precise-truck-742/instances/g-c-p-d-1662089401116/tables/test-data-api"
rows {
row_keys: "nonesuch"
}
,)
kwargs = {'metadata': [('x-goog-request-params', 'table_name=projects/precise-truck-742/instances/g-c-p-d-1662089401116/tables/test-data-api'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.49.0rc3 gax/2.10.0 gapic/2.11.3')], 'timeout': 61.0}
result = <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.NOT_FOUND
details = "Table not found: pro...nces/g-c-p-d-1662089401116/tables/test-data-api", grpc_status:5, created_time:"2022-09-02T03:30:33.112262448+00:00"}"
>
prefetch_first = True

@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
try:
result = callable_(*args, **kwargs)
# Auto-fetching the first result causes PubSub client's streaming pull
# to hang when re-opening the stream, thus we need examine the hacky
# hidden flag to see if pre-fetching is disabled.
# https://github.com/googleapis/python-pubsub/issues/93#issuecomment-630762257
prefetch_first = getattr(callable_, "_prefetch_first_result_", True)
return _StreamingResponseIterator(
result, prefetch_first_result=prefetch_first
)
except grpc.RpcError as exc:
> raise exceptions.from_grpc_error(exc) from exc
E google.api_core.exceptions.NotFound: 404 Table not found: projects/precise-truck-742/instances/g-c-p-d-1662089401116/tables/test-data-api

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:166: NotFound
________ test_instance_create_app_profile_create_with_multi_cluster_ids ________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 240, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 240, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 240, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 240.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_client =
unique_suffix = '-1662089401116'
admin_instance_populated =
admin_cluster =
location_id = 'us-central1-c'
instance_labels = {'python-system': '2022-09-02t03-30-01'}
instances_to_delete = []
skip_on_emulator = None

def test_instance_create_app_profile_create_with_multi_cluster_ids(
admin_client,
unique_suffix,
admin_instance_populated,
admin_cluster,
location_id,
instance_labels,
instances_to_delete,
skip_on_emulator,
):
alt_instance_id = f"dif{unique_suffix}"
instance = admin_client.instance(
alt_instance_id,
instance_type=enums.Instance.Type.PRODUCTION,
labels=instance_labels,
)

serve_nodes = 1

alt_cluster_id_1 = f"{alt_instance_id}-c1"
cluster_1 = instance.cluster(
alt_cluster_id_1,
location_id=location_id,
serve_nodes=serve_nodes,
default_storage_type=enums.StorageType.HDD,
)

alt_cluster_id_2 = f"{alt_instance_id}-c2"
location_id_2 = "us-central1-f"
cluster_2 = instance.cluster(
alt_cluster_id_2,
location_id=location_id_2,
serve_nodes=serve_nodes,
default_storage_type=enums.StorageType.HDD,
)
operation = instance.create(clusters=[cluster_1, cluster_2])
instances_to_delete.append(instance)
> operation.result(timeout=240) # Ensure the operation completes.

tests/system/test_instance_admin.py:441:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 240, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
_____________________________ test_cluster_create ______________________________

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 60, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
> return target()

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:190:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
retry =

def _done_or_raise(self, retry=DEFAULT_RETRY):
"""Check if the future is done and raise if it's not."""
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}

if not self.done(**kwargs):
> raise _OperationNotComplete()
E google.api_core.future.polling._OperationNotComplete

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:89: _OperationNotComplete

The above exception was the direct cause of the following exception:

self =
timeout = 60, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
> retry_(self._done_or_raise)(**kwargs)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:110:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (), kwargs = {}
target = functools.partial(>)
sleep_generator =

@functools.wraps(func)
def retry_wrapped_func(*args, **kwargs):
"""A wrapper that calls target function with retry."""
target = functools.partial(func, *args, **kwargs)
sleep_generator = exponential_sleep_generator(
self._initial, self._maximum, multiplier=self._multiplier
)
> return retry_target(
target,
self._predicate,
sleep_generator,
self._deadline,
on_error=on_error,
)

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:283:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

target = functools.partial(>)
predicate = .if_exception_type_predicate at 0x7f243531e280>
sleep_generator =
deadline = 60, on_error = None

def retry_target(target, predicate, sleep_generator, deadline, on_error=None):
"""Call a function and retry if it fails.

This is the lowest-level retry helper. Generally, you'll use the
higher-level retry helper :class:`Retry`.

Args:
target(Callable): The function to call and retry. This must be a
nullary function - apply arguments with `functools.partial`.
predicate (Callable[Exception]): A callable used to determine if an
exception raised by the target should be considered retryable.
It should return True to retry or False otherwise.
sleep_generator (Iterable[float]): An infinite iterator that determines
how long to sleep between retries.
deadline (float): How long to keep retrying the target. The last sleep
period is shortened as necessary, so that the last retry runs at
``deadline`` (and not considerably beyond it).
on_error (Callable[Exception]): A function to call while processing a
retryable exception. Any error raised by this function will *not*
be caught.

Returns:
Any: the return value of the target function.

Raises:
google.api_core.RetryError: If the deadline is exceeded while retrying.
ValueError: If the sleep generator stops yielding values.
Exception: If the target raises a method that isn't retryable.
"""
if deadline is not None:
deadline_datetime = datetime_helpers.utcnow() + datetime.timedelta(
seconds=deadline
)
else:
deadline_datetime = None

last_exc = None

for sleep in sleep_generator:
try:
return target()

# pylint: disable=broad-except
# This function explicitly must deal with broad exceptions.
except Exception as exc:
if not predicate(exc):
raise
last_exc = exc
if on_error is not None:
on_error(exc)

now = datetime_helpers.utcnow()

if deadline_datetime is not None:
if deadline_datetime <= now:
> raise exceptions.RetryError(
"Deadline of {:.1f}s exceeded while calling target function".format(
deadline
),
last_exc,
) from last_exc
E google.api_core.exceptions.RetryError: Deadline of 60.0s exceeded while calling target function, last exception:

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/retry.py:205: RetryError

During handling of the above exception, another exception occurred:

admin_instance_populated =
admin_instance_id = 'g-c-p-1662089401116', skip_on_emulator = None

def test_cluster_create(
admin_instance_populated,
admin_instance_id,
skip_on_emulator,
):
alt_cluster_id = f"{admin_instance_id}-c2"
alt_location_id = "us-central1-f"
serve_nodes = 2

cluster_2 = admin_instance_populated.cluster(
alt_cluster_id,
location_id=alt_location_id,
serve_nodes=serve_nodes,
default_storage_type=(enums.StorageType.SSD),
)
operation = cluster_2.create()
> operation.result(timeout=60) # Ensure the operation completes.

tests/system/test_instance_admin.py:682:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:132: in result
self._blocking_poll(timeout=timeout, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self =
timeout = 60, retry =

def _blocking_poll(self, timeout=None, retry=DEFAULT_RETRY):
"""Poll and wait 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._result_set:
return

retry_ = self._retry.with_deadline(timeout)

try:
kwargs = {} if retry is DEFAULT_RETRY else {"retry": retry}
retry_(self._done_or_raise)(**kwargs)
except exceptions.RetryError:
> raise concurrent.futures.TimeoutError(
"Operation did not complete within the designated " "timeout."
)
E concurrent.futures._base.TimeoutError: Operation did not complete within the designated timeout.

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/future/polling.py:112: TimeoutError
______________________ test_cluster_create_w_autoscaling _______________________

args = (parent: "projects/precise-truck-742/instances/g-c-p-1662089401116"
cluster_id: "g-c-p-1662089401116-c2"
cluster {
l... }
autoscaling_targets {
cpu_utilization_percent: 20
}
}
}
default_storage_type: SSD
}
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/precise-truck-742/instances/g-c-p-1662089401116'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.49.0rc3 gax/2.10.0')]}

@functools.wraps(callable_)
def error_remapped_callable(*args, **kwargs):
try:
> return callable_(*args, **kwargs)

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

self =
request = parent: "projects/precise-truck-742/instances/g-c-p-1662089401116"
cluster_id: "g-c-p-1662089401116-c2"
cluster {
lo... }
autoscaling_targets {
cpu_utilization_percent: 20
}
}
}
default_storage_type: SSD
}

timeout = None
metadata = [('x-goog-request-params', 'parent=projects/precise-truck-742/instances/g-c-p-1662089401116'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.49.0rc3 gax/2.10.0')]
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/prerelease_deps-3-8/lib/python3.8/site-packages/grpc/_channel.py:946:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

state =
call =
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.ALREADY_EXISTS
E details = "Cluster already exists in us-central1-f: projects/precise-truck-742/instances/g-c-p-1662089401116/clusters/g-c-p-1662089401116-c2"
E debug_error_string = "UNKNOWN:Error received from peer ipv4:74.125.195.95:443 {grpc_message:"Cluster already exists in us-central1-f: projects/precise-truck-742/instances/g-c-p-1662089401116/clusters/g-c-p-1662089401116-c2", grpc_status:6, created_time:"2022-09-02T03:39:04.992933674+00:00"}"
E >

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/grpc/_channel.py:849: _InactiveRpcError

The above exception was the direct cause of the following exception:

admin_instance_populated =
admin_instance_id = 'g-c-p-1662089401116', skip_on_emulator = None

def test_cluster_create_w_autoscaling(
admin_instance_populated,
admin_instance_id,
skip_on_emulator,
):
alt_cluster_id = f"{admin_instance_id}-c2"
alt_location_id = "us-central1-f"
min_serve_nodes = 1
max_serve_nodes = 8
cpu_utilization_percent = 20

cluster_2 = admin_instance_populated.cluster(
alt_cluster_id,
location_id=alt_location_id,
min_serve_nodes=min_serve_nodes,
max_serve_nodes=max_serve_nodes,
cpu_utilization_percent=cpu_utilization_percent,
default_storage_type=(enums.StorageType.SSD),
)
> operation = cluster_2.create()

tests/system/test_instance_admin.py:719:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
google/cloud/bigtable/cluster.py:383: in create
return client.instance_admin_client.create_cluster(
google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/client.py:1182: in create_cluster
response = rpc(
.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py:154: in __call__
return wrapped_func(*args, **kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

args = (parent: "projects/precise-truck-742/instances/g-c-p-1662089401116"
cluster_id: "g-c-p-1662089401116-c2"
cluster {
l... }
autoscaling_targets {
cpu_utilization_percent: 20
}
}
}
default_storage_type: SSD
}
,)
kwargs = {'metadata': [('x-goog-request-params', 'parent=projects/precise-truck-742/instances/g-c-p-1662089401116'), ('x-goog-api-client', 'gl-python/3.8.13 grpc/1.49.0rc3 gax/2.10.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.AlreadyExists: 409 Cluster already exists in us-central1-f: projects/precise-truck-742/instances/g-c-p-1662089401116/clusters/g-c-p-1662089401116-c2

.nox/prerelease_deps-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py:74: AlreadyExists
- generated xml file: /tmpfs/src/github/python-bigtable/system_3.8_sponge_log.xml -
=========================== short test summary info ============================
FAILED tests/system/test_data_api.py::test_access_with_non_admin_client - goo...
FAILED tests/system/test_instance_admin.py::test_instance_create_app_profile_create_with_multi_cluster_ids
FAILED tests/system/test_instance_admin.py::test_cluster_create - concurrent....
FAILED tests/system/test_instance_admin.py::test_cluster_create_w_autoscaling
ERROR tests/system/test_data_api.py::test_table_read_rows_filter_millis - con...
ERROR tests/system/test_data_api.py::test_table_mutate_rows - concurrent.futu...
ERROR tests/system/test_data_api.py::test_table_truncate - concurrent.futures...
ERROR tests/system/test_data_api.py::test_table_drop_by_prefix - concurrent.f...
ERROR tests/system/test_data_api.py::test_table_read_rows_w_row_set - concurr...
ERROR tests/system/test_data_api.py::test_rowset_add_row_range_w_pfx - concur...
ERROR tests/system/test_data_api.py::test_table_read_row_large_cell - concurr...
ERROR tests/system/test_data_api.py::test_table_read_row - concurrent.futures...
ERROR tests/system/test_data_api.py::test_table_read_rows - concurrent.future...
ERROR tests/system/test_data_api.py::test_read_with_label_applied - concurren...
ERROR tests/system/test_table_admin.py::test_instance_list_tables - concurren...
ERROR tests/system/test_table_admin.py::test_table_exists - concurrent.future...
ERROR tests/system/test_table_admin.py::test_table_create - concurrent.future...
ERROR tests/system/test_table_admin.py::test_table_create_w_families - concur...
ERROR tests/system/test_table_admin.py::test_table_create_w_split_keys - conc...
ERROR tests/system/test_table_admin.py::test_column_family_create - concurren...
ERROR tests/system/test_table_admin.py::test_column_family_update - concurren...
ERROR tests/system/test_table_admin.py::test_column_family_delete - concurren...
ERROR tests/system/test_table_admin.py::test_table_get_iam_policy - concurren...
ERROR tests/system/test_table_admin.py::test_table_set_iam_policy - concurren...
ERROR tests/system/test_table_admin.py::test_table_test_iam_permissions - con...
ERROR tests/system/test_table_admin.py::test_table_backup - concurrent.future...
======== 4 failed, 15 passed, 1 skipped, 22 errors in 574.45s (0:09:34) ========
nox > Command py.test --verbose --junitxml=system_3.8_sponge_log.xml tests/system failed with exit code 1
nox > Session prerelease_deps-3.8 failed.
[FlakyBot] Sending logs to Flaky Bot...
[FlakyBot] See https://github.com/googleapis/repo-automation-bots/tree/main/packages/flakybot.
[FlakyBot] Published system_3.8_sponge_log.xml (5514599857277453)!
[FlakyBot] Done!
cleanup


[ID: 7559003] Command finished after 663 secs, exit value: 1


Warning: Permanently added 'localhost' (ED25519) to the list of known hosts.
[20:39:38] Collecting build artifacts from build VM
Build script failed with exit code: 1