[Bug]: --dataflow_job_file does not work with direct runner

[dannikay]

What happened?

I'm trying to inspect the workflow graph generated by Beam without submitting the job to Dataflow. So I used the following command:

python -m wordcount --runner DirectRunner --dataflow_job_file ./debug.txt

However the "dataflow job file" was not dumped and there is no error executing the above command:

INFO:apache_beam.runners.worker.statecache:Creating state cache with size 104857600
WARNING:apache_beam.io.filebasedsink:Deleting 1 existing files in target path matching: -*-of-%(num_shards)05d
INFO:apache_beam.io.filebasedsink:Starting finalize_write threads with num_shards: 1 (skipped: 0), batches: 1, num_threads: 1
INFO:apache_beam.io.filebasedsink:Renamed 1 shards in 0.00 seconds.

Issue Priority

Priority: 3 (minor)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner