I was trying to run a @ValidatesRunner test for the streaming dataflow runner, but I actually can't find any way to run them in streaming. It looks like all the tests are set up using the Create transform, which generates a batch pipeline.
Are there actually no @ValidatesRunner tests for the streaming dataflow runner? That seems like a big gap in coverage. Am I missing a setting somewhere?
