shunping opened a new pull request, #38537:
URL: https://github.com/apache/beam/pull/38537
The PR fixes the race condition that causes the following flaky test.
```
_______ InteractiveBeamComputeTest.test_async_computation_result_cancel
________
[gw4] linux -- Python 3.13.13
/runner/_work/beam/beam/sdks/python/test-suites/tox/py313/build/srcs/sdks/python/target/.tox-py313-cloud/py313-cloud/bin/python
target/.tox-py313-cloud/py313-cloud/lib/python3.13/site-packages/apache_beam/runners/interactive/testing/mock_env.py:75:
in tearDown
self.current_env.cleanup()
target/.tox-py313-cloud/py313-cloud/lib/python3.13/site-packages/apache_beam/runners/interactive/interactive_environment.py:306:
in cleanup
self.evict_tracked_pipelines(pipeline)
target/.tox-py313-cloud/py313-cloud/lib/python3.13/site-packages/apache_beam/runners/interactive/interactive_environment.py:627:
in evict_tracked_pipelines
self._tracked_user_pipelines.clear()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _
self =
<apache_beam.runners.interactive.user_pipeline_tracker.UserPipelineTracker
object at 0x7d5e0c53c4d0>
def clear(self) -> None:
"""Clears the tracker of all user and derived pipelines."""
# Remove all local_tempdir of created pipelines.
> for p in self._pid_to_pipelines.values():
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
E RuntimeError: dictionary changed size during iteration
target/.tox-py313-cloud/py313-cloud/lib/python3.13/site-packages/apache_beam/runners/interactive/user_pipeline_tracker.py:71:
RuntimeError
```
--
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]
