apache_beam.runners.direct.test_direct_runner module

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

class apache_beam.runners.direct.test_direct_runner.TestDirectRunner[source]

Bases: apache_beam.runners.direct.direct_runner.SwitchingDirectRunner

run_pipeline(pipeline, options)[source]

Execute test pipeline and verify test matcher