diff --git a/sdks/python/apache_beam/runners/worker/logger_test.py b/sdks/python/apache_beam/runners/worker/logger_test.py index 5e6a0651632f5..c131775b8e098 100644 --- a/sdks/python/apache_beam/runners/worker/logger_test.py +++ b/sdks/python/apache_beam/runners/worker/logger_test.py @@ -27,9 +27,9 @@ import unittest from builtins import object -from apache_beam.utils.counters import CounterFactory from apache_beam.runners.worker import logger from apache_beam.runners.worker import statesampler +from apache_beam.utils.counters import CounterFactory class PerThreadLoggingContextTest(unittest.TestCase):