[beam] branch master updated: [BEAM-9707] Remove hardcoded unified harness image

[go...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

goenka 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 8825995  [BEAM-9707] Remove hardcoded unified harness image
     new 05f676e  Merge pull request #12044 from angoenka/cleanup_uw_image
8825995 is described below

commit 8825995dffbe9ac5d9ea17a74e207a68c7ff25cc
Author: Ankur Goenka <an...@gmail.com>
AuthorDate: Fri Jun 19 18:08:30 2020 -0700

    [BEAM-9707] Remove hardcoded unified harness image
---
 sdks/python/apache_beam/runners/dataflow/internal/apiclient.py | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
index 4fb7e6a..d474849 100644
--- a/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
+++ b/sdks/python/apache_beam/runners/dataflow/internal/apiclient.py
@@ -196,16 +196,6 @@ class Environment(object):
     if job_type.startswith('FNAPI_'):
       self.debug_options.experiments = self.debug_options.experiments or []
 
-      # TODO(BEAM-9707) : Remove hardcoding runner_harness_container for
-      #  Unified worker.
-      if _use_unified_worker(
-          options) and not self.debug_options.lookup_experiment(
-              'runner_harness_container_image'
-          ) and 'dev' in beam_version.__version__:
-        self.debug_options.add_experiment(
-            'runner_harness_container_image='
-            'gcr.io/cloud-dataflow/v1beta3/unified-harness:20200409-rc00')
-
       if self.debug_options.lookup_experiment(
           'runner_harness_container_image') or _use_unified_worker(options):
         # Default image is not used if user provides a runner harness image.