From 8cbc45bf66ccbea66ad2dd8033a720e916b4e795 Mon Sep 17 00:00:00 2001 From: cclauss Date: Wed, 9 May 2018 01:04:17 +0200 Subject: [PATCH] Undefined names: import MetricKey, MetricName As mentioned at https://github.com/apache/beam/commit/582fcea913b2fe84d771df4a4467fff887af9842#r28136702 these two variables are undefined names in this context. This PR imports them to resolve the undefined names. --- .../apache_beam/runners/portability/fn_api_runner_test.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py b/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py index faad561f54b0..63af2847b56d 100644 --- a/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py +++ b/sdks/python/apache_beam/runners/portability/fn_api_runner_test.py @@ -25,7 +25,9 @@ import unittest import apache_beam as beam +from apache_beam.metrics.execution import MetricKey from apache_beam.metrics.execution import MetricsEnvironment +from apache_beam.metrics.metricbase import MetricName from apache_beam.runners.portability import fn_api_runner from apache_beam.runners.worker import sdk_worker from apache_beam.runners.worker import statesampler