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: apache_beam.runners.dataflow.dataflow_runner.DataflowRunner

run(pipeline)[source]

Execute test pipeline and verify test matcher