Run Pipeline different runners

pipeline_start.py

if options.view_as(StandardOptions).runner in ("DirectRunner", None):
    pubsub_id = None
    with beam.Pipeline(options=options) as p:
        _run_pipeline(p, pubsub_id, file_processing_options, gcp_project)

elif options.view_as(StandardOptions).runner == "DataflowRunner":
    pipeline = beam.Pipeline(options=options)
    _run_pipeline(pipeline, pubsub_id, file_processing_options, gcp_project)
    pipeline.run()
else:
    raise Exception("Unknown runner")

def _run_pipeline(pipeline, pubsub_id, file_options, gcp_project):
	print("Here the pipeline")