Doesn't PAssertTest.runExpectingAssertionFailure need to call waitUntilFinish?

[Shen Li]

Hi,

In the PAssertTest, doesn't it need to append a "waitUntilFinish()" to the
"pipeline.run()" (please see the link below)? Otherwise, the runner may
return the PipelineResult immediately without actually kicking off the
execution, and therefore the AssertionError won't be thrown. Or did I miss
anything?

https://github.com/apache/beam/blob/master/sdks/java/core/src/test/java/org/apache/beam/sdk/testing/PAssertTest.java#L399

Thanks,

Shen