public class TestPortableRunner extends PipelineRunner<PipelineResult>
TestPortableRunner
is a pipeline runner that wraps a PortableRunner
when running
tests against the TestPipeline
.
This runner requires a JobServerDriver
subclass with the following factory method:
public static JobServerDriver fromParams(String[] args)
TestPipeline
Modifier and Type | Method and Description |
---|---|
static TestPortableRunner |
fromOptions(PipelineOptions options) |
PipelineResult |
run(Pipeline pipeline)
Processes the given
Pipeline , potentially asynchronously, returning a runner-specific
type of result. |
create, run, run
public static TestPortableRunner fromOptions(PipelineOptions options)
public PipelineResult run(Pipeline pipeline)
PipelineRunner
Pipeline
, potentially asynchronously, returning a runner-specific
type of result.run
in class PipelineRunner<PipelineResult>