hjtran commented on PR #35601:
URL: https://github.com/apache/beam/pull/35601#issuecomment-3078577011
I could use some help debugging the failing unit test. It passes locally for
me but seems to fail on the GH Runner for some reason due to a grpc timeout:
```
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-07-16T11:40:51.901440152+00:00"}"
>
self = <apache_beam.transforms.combiners_test.CombinerWithSideInputs
testMethod=test_cpk_with_windows>
def test_cpk_with_windows(self):
# With global window side input
> with TestPipeline() as p:
apache_beam/transforms/combiners_test.py:1173:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _
target/.tox-py311-cloud/py311-cloud/lib/python3.11/site-packages/apache_beam/pipeline.py:661:
in __exit__
self.result = self.run()
target/.tox-py311-cloud/py311-cloud/lib/python3.11/site-packages/apache_beam/testing/test_pipeline.py:119:
in run
state = result.wait_until_finish()
target/.tox-py311-cloud/py311-cloud/lib/python3.11/site-packages/apache_beam/runners/portability/portable_runner.py:568:
in wait_until_finish
raise self._runtime_exception
target/.tox-py311-cloud/py311-cloud/lib/python3.11/site-packages/apache_beam/runners/portability/portable_runner.py:574:
in _observe_state
for state_response in self._state_stream:
target/.tox-py311-cloud/py311-cloud/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-07-16T11:40:51.901440152+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-07-16T11:40:51.901440152+00:00"}"
E >
target/.tox-py311-cloud/py311-cloud/lib/python3.11/site-packages/grpc/_channel.py:969:
_MultiThreadedRendezvous
```
--
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: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
