[ https://issues.apache.org/jira/browse/BEAM-2796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Groh updated BEAM-2796: ------------------------------ Component/s: (was: runner-direct) sdk-py > _ExecutorServiceParallelExecutor.await_for_completion does not actually await > for _ExecutorService to shutdown > -------------------------------------------------------------------------------------------------------------- > > Key: BEAM-2796 > URL: https://issues.apache.org/jira/browse/BEAM-2796 > Project: Beam > Issue Type: Bug > Components: sdk-py > Affects Versions: 2.2.0 > Reporter: Sergiy Byelozyorov > Assignee: Thomas Groh > > It's missing a call to self.executor_service.await_completion() -- This message was sent by Atlassian JIRA (v6.4.14#64029)