Repository: beam Updated Branches: refs/heads/master ffd99cb43 -> 63bcd3916
fix python lint errors Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/87e0fdc4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/87e0fdc4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/87e0fdc4 Branch: refs/heads/master Commit: 87e0fdc43666a376d78af36e35e24d734da4c8a7 Parents: ffd99cb Author: Ahmet Altay <al...@google.com> Authored: Thu Jun 1 11:12:56 2017 -0700 Committer: Ahmet Altay <al...@google.com> Committed: Thu Jun 1 11:12:56 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/portability/fn_api_runner.py | 2 +- sdks/python/apache_beam/runners/worker/data_plane_test.py | 2 +- sdks/python/apache_beam/runners/worker/log_handler_test.py | 2 +- sdks/python/apache_beam/runners/worker/sdk_worker_test.py | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/87e0fdc4/sdks/python/apache_beam/runners/portability/fn_api_runner.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner.py b/sdks/python/apache_beam/runners/portability/fn_api_runner.py index 2635559..db34ef9 100644 --- a/sdks/python/apache_beam/runners/portability/fn_api_runner.py +++ b/sdks/python/apache_beam/runners/portability/fn_api_runner.py @@ -23,8 +23,8 @@ import logging import Queue as queue import threading -import grpc from concurrent import futures +import grpc import apache_beam as beam from apache_beam.coders import WindowedValueCoder http://git-wip-us.apache.org/repos/asf/beam/blob/87e0fdc4/sdks/python/apache_beam/runners/worker/data_plane_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/worker/data_plane_test.py b/sdks/python/apache_beam/runners/worker/data_plane_test.py index 7340789..e3e01ac 100644 --- a/sdks/python/apache_beam/runners/worker/data_plane_test.py +++ b/sdks/python/apache_beam/runners/worker/data_plane_test.py @@ -26,8 +26,8 @@ import sys import threading import unittest -import grpc from concurrent import futures +import grpc from apache_beam.runners.api import beam_fn_api_pb2 from apache_beam.runners.worker import data_plane http://git-wip-us.apache.org/repos/asf/beam/blob/87e0fdc4/sdks/python/apache_beam/runners/worker/log_handler_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/worker/log_handler_test.py b/sdks/python/apache_beam/runners/worker/log_handler_test.py index 565bedb..8720ca8 100644 --- a/sdks/python/apache_beam/runners/worker/log_handler_test.py +++ b/sdks/python/apache_beam/runners/worker/log_handler_test.py @@ -19,8 +19,8 @@ import logging import unittest -import grpc from concurrent import futures +import grpc from apache_beam.runners.api import beam_fn_api_pb2 from apache_beam.runners.worker import log_handler http://git-wip-us.apache.org/repos/asf/beam/blob/87e0fdc4/sdks/python/apache_beam/runners/worker/sdk_worker_test.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker_test.py b/sdks/python/apache_beam/runners/worker/sdk_worker_test.py index 996f44c..0d0811b 100644 --- a/sdks/python/apache_beam/runners/worker/sdk_worker_test.py +++ b/sdks/python/apache_beam/runners/worker/sdk_worker_test.py @@ -24,8 +24,8 @@ from __future__ import print_function import logging import unittest -import grpc from concurrent import futures +import grpc from apache_beam.io.concat_source_test import RangeSource from apache_beam.io.iobase import SourceBundle
