[BEAM-10959] Fix race where split/progress calls return "Unknown process bundle instruction"

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Missing
• Component/s: sdk-py-harness
• Assignee: Luke Cwik
• Reporter: Luke Cwik
• Created: 23/Sep/20 20:37
• Updated: 13/Jan/22 21:48
• Resolved: 15/May/21 17:59

Description

Currently there is a race where a BundleProcessor doesn't exist until another thread picks up the task and inserts into the active set. This allows for split/progress calls to happen and error out with "Unknown process bundle instruction X".

Since the control stream is ordered, we can guarantee that an uninitialized BundleProcessor exists that can respond to this really early split/progress calls.

Issue Links

• links to: GitHub Pull Request #12934
• links to: GitHub Pull Request #12948
• links to: GitHub Pull Request #13123