From 485a781538344b744596f4f5a9b6eb6b16d0ce0f Mon Sep 17 00:00:00 2001 From: Craig Chambers Date: Tue, 9 Jul 2019 12:47:17 -0700 Subject: [PATCH] Update Python Dataflow runner to patch side input coders on the unified worker, too --- sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py index 1b6ad16abd472..4c2a10fc2cd0a 100644 --- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py +++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py @@ -369,8 +369,7 @@ def run_pipeline(self, pipeline, options): 'please install apache_beam[gcp]') # Convert all side inputs into a form acceptable to Dataflow. - if apiclient._use_fnapi(options) and ( - not apiclient._use_unified_worker(options)): + if apiclient._use_fnapi(options): pipeline.visit(self.side_input_visitor()) # Performing configured PTransform overrides. Note that this is currently