Repository: beam Updated Branches: refs/heads/master 12e79d0a0 -> 1259ee955
Enable discovery of log_handler tests. Also fix the one remaining bug. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5fb3aa03 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5fb3aa03 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5fb3aa03 Branch: refs/heads/master Commit: 5fb3aa03a4f018fb54cc5b65fc74920e0b7983b3 Parents: 12e79d0 Author: Robert Bradshaw <[email protected]> Authored: Wed Oct 4 17:38:43 2017 -0700 Committer: Robert Bradshaw <[email protected]> Committed: Thu Oct 5 08:53:30 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/worker/log_handler.py | 1 + sdks/python/apache_beam/runners/worker/log_handler_test.py | 7 ++++--- 2 files changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/5fb3aa03/sdks/python/apache_beam/runners/worker/log_handler.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/worker/log_handler.py b/sdks/python/apache_beam/runners/worker/log_handler.py index 8691184..6d8a1d9 100644 --- a/sdks/python/apache_beam/runners/worker/log_handler.py +++ b/sdks/python/apache_beam/runners/worker/log_handler.py @@ -24,6 +24,7 @@ import threading import grpc from apache_beam.portability.api import beam_fn_api_pb2 +from apache_beam.portability.api import beam_fn_api_pb2_grpc # This module is experimental. No backwards-compatibility guarantees. http://git-wip-us.apache.org/repos/asf/beam/blob/5fb3aa03/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 9814324..d2647d0 100644 --- a/sdks/python/apache_beam/runners/worker/log_handler_test.py +++ b/sdks/python/apache_beam/runners/worker/log_handler_test.py @@ -100,8 +100,9 @@ def _create_test(name, num_logs): lambda self: self._verify_fn_log_handler(num_logs)) -if __name__ == '__main__': - for test_name, num_logs_entries in data.iteritems(): - _create_test(test_name, num_logs_entries) +for test_name, num_logs_entries in data.iteritems(): + _create_test(test_name, num_logs_entries) + +if __name__ == '__main__': unittest.main()
