Note: #8021 was also for this test, but it was closed more than 10 days ago. So, I didn't mark it flaky.
commit: 6444bd2
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":"@1660216527.429624208","description":"Error received from peer ipv4:142.250.107.95:443","file":"src/core/lib/surface/call.cc","file_line":966,"grpc_message":"Already exists: Failed to create batch: Batch projects/python-docs-samples-tests/locations/us-central1/batches/summit-dag-test-64c6704e-3c61-4b20-b7ee-70b61778773e","grpc_status":6}"
>
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
Note: #8021 was also for this test, but it was closed more than 10 days ago. So, I didn't mark it flaky.
commit: 6444bd2
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":"@1660216527.429624208","description":"Error received from peer ipv4:142.250.107.95:443","file":"src/core/lib/surface/call.cc","file_line":966,"grpc_message":"Already exists: Failed to create batch: Batch projects/python-docs-samples-tests/locations/us-central1/batches/summit-dag-test-64c6704e-3c61-4b20-b7ee-70b61778773e","grpc_status":6}" >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