yoshiki obata created BEAM-10860:
------------------------------------
Summary: RuntimeError is potentially raised when
BundleProcessorCache.shutdown called
Key: BEAM-10860
URL: https://issues.apache.org/jira/browse/BEAM-10860
Project: Beam
Issue Type: Bug
Components: sdk-py-core
Reporter: yoshiki obata
Following codes in BundleProcessorCache.shutdown should raise RuntimeError:
dictionary changed size during iteration is raised.
{code:python}
for instruction_id in self.active_bundle_processors:
self.active_bundle_processors[instruction_id][1].shutdown()
del self.active_bundle_processors[instruction_id]{code}
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]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
