[ https://issues.apache.org/jira/browse/BEAM-10860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
yoshiki obata reassigned BEAM-10860: ------------------------------------ Assignee: yoshiki obata > 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 > Assignee: yoshiki obata > Priority: P2 > > 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)