Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
Following codes in BundleProcessorCache.shutdown should raise RuntimeError: dictionary changed size during iteration is raised.
for instruction_id in self.active_bundle_processors: self.active_bundle_processors[instruction_id][1].shutdown() del self.active_bundle_processors[instruction_id]
If active_bundle_processors is empty, these codes works fine.
I found this in following GitHub Actions;
https://github.com/apache/beam/actions/runs/234476619
Attachments
Issue Links
- relates to
-
BEAM-10866 PortableRunnerTestWithSubprocesses.test_register_finalizations flaky on macOS
- Open
- links to