Test pipeline for use by pubsub_integration_test.
apache_beam.io.gcp.pubsub_it_pipeline.
run_pipeline
Build and run the pipeline.