Update Python Dataflow runner to patch side input coders on the unifi…

…ed worker, too
kamilwu · Jul 9, 2019 · 485a781 · 485a781
1 parent 66bd44f
commit 485a781
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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