_ExecutorServiceParallelExecutor.await_for_completion does not actually await for _ExecutorService to shutdown
Open
bug
core
P3
python
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 2d 5h
- Merged PRs (30d)
- 204
Description
It's missing a call to self.executor_service.await_completion()
Imported from Jira [BEAM-2796](https://issues.apache.org/jira/browse/BEAM-2796). Original Jira may contain additional context.
Reported by: sergiyb.
Contributor guide
Research direction
Locate _ExecutorServiceParallelExecutor and its await_for_completion method, then read the ExecutorService API to confirm the expected shutdown-wait behavior. Verify that completion does not return until the executor service has shut down, and run the relevant existing executor tests if available.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- python
- Domain
- distributed-systems
- Issue type
- Bug
- Difficulty
- 2/5
- Estimated time
- 1-3 hours
- Activity status
- Stale
- Clarity
- Clearly specified
- Newbie friendliness
- 48/100