Hello Alexey. As I understand this annotation is used to check that test's
author write pipeline.run
(p.run().waitUntilFinish();) in the end of the test. It has > 300 usages in all
project. I think it is necessary here.
What should I do with this tests?
I can rewrite it like this:
` @Rule public TestPipeline p = TestPipeline.create()`
` .enableAbandonedNodeEnforcement(false)`
` .enableAutoRunIfMissing(true);`
` @Test` public void testExtractTempFn() {`
` PCollection<...> results = ...;`
` PAssert.that(results).containsInAnyOrder(ImmutableList.of(kv1, kv2, kv3));`
` }`
This approach will start pipeline automatically in the end of test (as I think)
[ Full content available at: https://github.com/apache/beam/pull/6542 ]
This message was relayed via gitbox.apache.org for [email protected]
