apache_beam.runners.dataflow.test_dataflow_runner module¶

Wrapper of Beam runners that’s built for running and verifying e2e tests.

class apache_beam.runners.dataflow.test_dataflow_runner.TestDataflowRunner(cache=None)[source]¶

Bases: DataflowRunner

run_pipeline(pipeline, options)[source]¶: Execute test pipeline and verify test matcher

build_console_url(options)[source]¶: Build a console url of Dataflow job.

wait_until_in_state(expected_state, timeout=600)[source]¶: Wait until Dataflow pipeline enters a certain state.