composer.2022_airflow_summit.data_analytics_process_test: test_process failed

[flaky-bot[bot]]

Note: #8021 was also for this test, but it was closed more than 10 days ago. So, I didn't mark it flaky.

---

commit: 6444bd2d5e4c6f768fa6056c5d73750966ed7c1e buildURL: Build Status, Sponge status: failed

Test output

Traceback (most recent call last):
  File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 50, in error_remapped_callable
    return callable_(*args, **kwargs)
  File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py", line 946, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_inactiverpcerror of rpc that terminated with: status="StatusCode.ALREADY_EXISTS" details="Already exists: Failed to create batch: Batch projects/python-docs-samples-tests/locations/us-central1/batches/summit-dag-test-64c6704e-3c61-4b20-b7ee-70b61778773e" debug_error_string="{" created received from peer ipv4:142.250.107.95:443 exists: failed to create batch: batch projects>
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/workspace/composer/2022_airflow_summit/data_analytics_process_test.py", line 145, in test_process
operation = dataproc_client.create_batch(request=request)
File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/cloud/dataproc_v1/services/batch_controller/client.py", line 555, in create_batch
response = rpc(
File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py", line 154, in call
return wrapped_func(*args, **kwargs)
File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 52, in error_remapped_callable
raise exceptions.from_grpc_error(exc) from exc
google.api_core.exceptions.AlreadyExists: 409 Already exists: Failed to create batch: Batch projects/python-docs-samples-tests/locations/us-central1/batches/summit-dag-test-64c6704e-3c61-4b20-b7ee-70b61778773e

[leahecole]

I think this is a flake, I'm closing for now but will keep an eye out for it again

[flaky-bot[bot]]

Looks like this issue is flaky. :worried:

I'm going to leave this open and stop commenting.

A human should fix and close this.

---

commit: a63091cdbde2536f2109bceaab7422f1261600ed buildURL: Build Status, Sponge status: failed

Test output

Traceback (most recent call last):
  File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 50, in error_remapped_callable
    return callable_(*args, **kwargs)
  File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py", line 946, in __call__
    return _end_unary_response_blocking(state, call, False, None)
  File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
    raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_inactiverpcerror of rpc that terminated with: status="StatusCode.ALREADY_EXISTS" details="Already exists: Failed to create batch: Batch projects/python-docs-samples-tests/locations/us-central1/batches/summit-dag-test-19c2b814-e054-4a03-826c-2f6cf71f0176" debug_error_string="{" created received from peer ipv4:74.125.142.95:443 exists: failed to create batch: batch projects>
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/workspace/composer/2022_airflow_summit/data_analytics_process_test.py", line 145, in test_process
operation = dataproc_client.create_batch(request=request)
File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/cloud/dataproc_v1/services/batch_controller/client.py", line 555, in create_batch
response = rpc(
File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py", line 154, in call
return wrapped_func(*args, **kwargs)
File "/workspace/composer/2022_airflow_summit/.nox/py-3-8/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 52, in error_remapped_callable
raise exceptions.from_grpc_error(exc) from exc
google.api_core.exceptions.AlreadyExists: 409 Already exists: Failed to create batch: Batch projects/python-docs-samples-tests/locations/us-central1/batches/summit-dag-test-19c2b814-e054-4a03-826c-2f6cf71f0176

[leahecole]

alright i'll examine for real