apache_beam.io.gcp.pubsub_it_pipeline module

Test pipeline for use by pubsub_integration_test.

apache_beam.io.gcp.pubsub_it_pipeline.run_pipeline(argv, with_attributes, id_label, timestamp_attribute)

Build and run the pipeline.