[BEAM-5794] TestDirectRunner: poll matchers for wait_until_finish_duration, then cancel the pipeline

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: sdk-py-core
• Assignee: Unassigned
• Reporter: Udi Meiri
• Created: 19/Oct/18 16:44
• Updated: 03/Jun/22 22:54

Description

In pubsub_integration_test.py and other uses of TestXXXRunner:

Fix TestDirectRunner to poll on_success_matcher for wait_until_finish_duration milliseconds.
Remove the timeout from PubSubMessageMatcher (rely on above polling)