ahmedabu98 commented on PR #23334: URL: https://github.com/apache/beam/pull/23334#issuecomment-1264081481
So looks like TestDirectRunner uses either `.wait_until_finish()` for batch pipelines or `on_success_matcher()` for streaming pipelines [when it runs](https://github.com/apache/beam/blob/8e217ea0d1f383ef5033ef507b14d01edf9c67e6/sdks/python/apache_beam/runners/direct/test_direct_runner.py#L45-L50). Otherwise, the `try` block is a noop and the pipeline is canceled in the following `finally` block. In other words, it is by design that `TestDirectRunner` needs `on_streaming_matcher()` in pipeline options for streaming pipelines. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
