From 6d1e3bef801a8d0625db79316e6e149f8714f1e6 Mon Sep 17 00:00:00 2001 From: Axel Magnuson Date: Wed, 7 Mar 2018 18:06:20 -0800 Subject: [PATCH] Bugfix changes from apache/beam#4811 --- .../apache_beam/runners/portability/universal_local_runner.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/python/apache_beam/runners/portability/universal_local_runner.py b/sdks/python/apache_beam/runners/portability/universal_local_runner.py index befb0025a3fc3..737fef63b1939 100644 --- a/sdks/python/apache_beam/runners/portability/universal_local_runner.py +++ b/sdks/python/apache_beam/runners/portability/universal_local_runner.py @@ -31,6 +31,8 @@ import grpc from google.protobuf import text_format +from apache_beam import coders +from apache_beam.internal import pickler from apache_beam.portability.api import beam_fn_api_pb2_grpc from apache_beam.portability.api import beam_job_api_pb2 from apache_beam.portability.api import beam_job_api_pb2_grpc