This is an automated email from the ASF dual-hosted git repository. yichi pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push: new 818ee3b Revert "Avoid apiary submission of job graph when it is not needed. (#15458)" new f11a5bb Merge pull request #15592 from robertwb/no-upload-graph 818ee3b is described below commit 818ee3bb384e890dc55fa937eee028ea4d1fd61e Author: Robert Bradshaw <rober...@gmail.com> AuthorDate: Fri Sep 24 16:29:07 2021 -0700 Revert "Avoid apiary submission of job graph when it is not needed. (#15458)" This reverts commit a63e15f714765f4f89d166c12430ee433a695e51. This avoids regressions from missing display data that was being copied from the v1beta3 graph. --- sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 7 ------- 1 file changed, 7 deletions(-) diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py index 29a6016..bbaf52c 100644 --- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py +++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py @@ -508,13 +508,6 @@ class DataflowRunner(PipelineRunner): # in the proto representation of the graph. pipeline.replace_all(DataflowRunner._NON_PORTABLE_PTRANSFORM_OVERRIDES) - # Always upload graph out-of-band when explicitly using runner v2 with - # use_portable_job_submission to avoid irrelevant large graph limits. - if (apiclient._use_unified_worker(debug_options) and - debug_options.lookup_experiment('use_portable_job_submission') and - not debug_options.lookup_experiment('upload_graph')): - debug_options.add_experiment("upload_graph") - # Add setup_options for all the BeamPlugin imports setup_options = options.view_as(SetupOptions) plugins = BeamPlugin.get_all_plugin_paths()