robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492422441
##
File path: sdks/python/apache_beam/runners/portability/stager.py
##
@@ -119,6 +119,7 @@ def create_job_resources(options, # type: PipelineOptions
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492504554
##
File path: sdks/python/apache_beam/runners/portability/sdk_container_builder.py
##
@@ -0,0 +1,274 @@
+#
+# Licensed to the Apache Software Foundation (
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492504467
##
File path: sdks/python/apache_beam/runners/portability/sdk_container_builder.py
##
@@ -0,0 +1,274 @@
+#
+# Licensed to the Apache Software Foundation (
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492191803
##
File path: sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
##
@@ -473,10 +474,19 @@ def run_pipeline(self, pipeline, options):
use_f
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492422441
##
File path: sdks/python/apache_beam/runners/portability/stager.py
##
@@ -119,6 +119,7 @@ def create_job_resources(options, # type: PipelineOptions
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492283727
##
File path: sdks/python/apache_beam/runners/portability/stager.py
##
@@ -119,6 +119,7 @@ def create_job_resources(options, # type: PipelineOptions
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492195972
##
File path: sdks/python/apache_beam/runners/portability/stager.py
##
@@ -119,6 +119,7 @@ def create_job_resources(options, # type: PipelineOptions
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r492191803
##
File path: sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
##
@@ -473,10 +474,19 @@ def run_pipeline(self, pipeline, options):
use_f
robertwb commented on a change in pull request #12727:
URL: https://github.com/apache/beam/pull/12727#discussion_r490632829
##
File path: sdks/python/apache_beam/options/pipeline_options.py
##
@@ -994,6 +994,23 @@ def _add_argparse_args(cls, parser):
'staged in the