[Cherry-pick] Add new method of generating key for GBEK (#36891) #36967
GitHub Actions / Test Results
failed
Dec 3, 2025 in 0s
1 fail, 84 skipped, 884 pass in 12m 45s
4 files 4 suites 12m 45s ⏱️
969 tests 884 ✅ 84 💤 1 ❌
1 955 runs 1 759 ✅ 195 💤 1 ❌
Results for commit 5692cdc.
Annotations
Check warning on line 0 in apache_beam.transforms.util_test.RegexTest
github-actions / Test Results
1 out of 2 runs failed: test_split_with_empty (apache_beam.transforms.util_test.RegexTest)
sdks/python/test-suites/tox/py311/build/srcs/sdks/python/pytest_py311.xml [took 5m 0s]
Raw output
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.DEADLINE_EXCEEDED
details = "Deadline Exceeded"
debug_error_string = "UNKNOWN:Error received from peer {grpc_message:"Deadline Exceeded", grpc_status:4, created_time:"2025-12-03T16:24:23.220610011+00:00"}"
>
self = <apache_beam.transforms.util_test.RegexTest testMethod=test_split_with_empty>
def test_split_with_empty(self):
> with TestPipeline() as p:
apache_beam/transforms/util_test.py:2445:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
target/.tox-py311/py311/lib/python3.11/site-packages/apache_beam/pipeline.py:646: in __exit__
self.result = self.run()
^^^^^^^^^^
target/.tox-py311/py311/lib/python3.11/site-packages/apache_beam/testing/test_pipeline.py:122: in run
state = result.wait_until_finish(duration=self.timeout)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
target/.tox-py311/py311/lib/python3.11/site-packages/apache_beam/runners/portability/portable_runner.py:571: in wait_until_finish
raise self._runtime_exception
target/.tox-py311/py311/lib/python3.11/site-packages/apache_beam/runners/portability/portable_runner.py:580: in _observe_state
for state_response in self._state_stream:
target/.tox-py311/py311/lib/python3.11/site-packages/grpc/_channel.py:543: in __next__
return self._next()
^^^^^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.DEADLINE_EXCEEDED
details = "Deadline Exc...ved from peer {grpc_message:"Deadline Exceeded", grpc_status:4, created_time:"2025-12-03T16:24:23.220610011+00:00"}"
>
def _next(self) -> Any:
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.DEADLINE_EXCEEDED
E details = "Deadline Exceeded"
E debug_error_string = "UNKNOWN:Error received from peer {grpc_message:"Deadline Exceeded", grpc_status:4, created_time:"2025-12-03T16:24:23.220610011+00:00"}"
E >
target/.tox-py311/py311/lib/python3.11/site-packages/grpc/_channel.py:969: _MultiThreadedRendezvous
Loading