shunping opened a new pull request, #38526: URL: https://github.com/apache/beam/pull/38526
The exception here is mostly harmless. Changing it to a warning message and make the test log cleaner. https://github.com/apache/beam/actions/runs/26003104622/job/76429819073 ``` Exception in thread run_worker_job-202[job]_ref_Environment_default_environment_1: Traceback (most recent call last): File "/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/threading.py", line 1075, in _bootstrap_inner self.run() File "/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/threading.py", line 1012, in run self._target(*self._args, **self._kwargs) File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/runners/worker/sdk_worker.py", line 265, in run for work_request in self._control_stub.Control(get_responses()): ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/grpc/_channel.py", line 538, in __next__ return self._next() ^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/grpc/_channel.py", line 956, in _next raise self grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.UNAVAILABLE details = "Socket closed" debug_error_string = "UNKNOWN:Error received from peer ipv4:127.0.0.1:45545 {grpc_message:"Socket closed", grpc_status:14}" > ERROR:apache_beam.runners.worker.data_plane:Failed to read inputs in the data plane. Traceback (most recent call last): File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/runners/worker/data_plane.py", line 719, in _read_inputs for elements in elements_iterator: ^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/grpc/_channel.py", line 538, in __next__ return self._next() ^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/grpc/_channel.py", line 956, in _next raise self grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.UNAVAILABLE details = "Socket closed" debug_error_string = "UNKNOWN:Error received from peer ipv4:127.0.0.1:45545 {grpc_message:"Socket closed", grpc_status:14}" > Exception in thread read_grpc_client_inputs: Traceback (most recent call last): File "/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/threading.py", line 1075, in _bootstrap_inner self.run() File "/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/threading.py", line 1012, in run self._target(*self._args, **self._kwargs) File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/runners/worker/data_plane.py", line 736, in <lambda> target=lambda: self._read_inputs(elements_iterator), ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/runners/worker/data_plane.py", line 719, in _read_inputs for elements in elements_iterator: ^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/grpc/_channel.py", line 538, in __next__ return self._next() ^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/grpc/_channel.py", line 956, in _next raise self grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.UNAVAILABLE details = "Socket closed" debug_error_string = "UNKNOWN:Error received from peer ipv4:127.0.0.1:45545 {grpc_message:"Socket closed", grpc_status:14}" > Exception ignored in atexit callback: <bound method InteractiveEnvironment.cleanup of <apache_beam.runners.interactive.interactive_environment.InteractiveEnvironment object at 0x787b14391670>> Traceback (most recent call last): File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/runners/interactive/interactive_environment.py", line 298, in cleanup self.cleanup_environment() File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/runners/interactive/interactive_environment.py", line 288, in cleanup_environment cache_manager.cleanup() File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/runners/interactive/cache_manager.py", line 293, in cleanup fs.delete([self._cache_dir + '/full/']) File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/io/gcp/gcsfilesystem.py", line 357, in delete self._gcsIO().delete(path, recursive=True) File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/apache_beam/io/gcp/gcsio.py", line 272, in delete f'gs://{bucket_name}/{blob.name}' for blob in blobs_to_delete ^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/page_iterator.py", line 208, in _items_iter for page in self._page_iter(increment=False): ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/page_iterator.py", line 244, in _page_iter page = self._next_page() ^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/page_iterator.py", line 373, in _next_page response = self._get_next_page_response() ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/page_iterator.py", line 432, in _get_next_page_response return self.api_request( ^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/cloud/storage/_http.py", line 90, in api_request return call() ^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py", line 294, in retry_wrapped_func return retry_target( ^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py", line 156, in retry_target next_sleep = _retry_error_helper( ^^^^^^^^^^^^^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/retry/retry_base.py", line 216, in _retry_error_helper raise final_exc from source_exc File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py", line 147, in retry_target result = target() ^^^^^^^^ File "/runner/_work/beam/beam/sdks/python/test-suites/tox/py312/build/srcs/sdks/python/target/.tox-py312-cloud/py312-cloud/lib/python3.12/site-packages/google/cloud/_http/__init__.py", line 494, in api_request raise exceptions.from_http_response(response) google.api_core.exceptions.Forbidden: 403 GET https://storage.googleapis.com/storage/v1/b/test-bucket/o?projection=noAcl&prefix=132468897523968%2Ffull%2F&prettyPrint=false: [email protected] does not have storage.objects.list access to the Google Cloud Storage bucket. Permission 'storage.objects.list' denied on resource (or it may not exist). ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
