Repository: beam Updated Branches: refs/heads/master d4ce94f4e -> 034bcb4e2
Remove overloading of __call__ in DirectRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9697e8c2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9697e8c2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9697e8c2 Branch: refs/heads/master Commit: 9697e8c2c916fb0af2557cb6ed5a91e8879eb433 Parents: d4ce94f Author: Charles Chen <[email protected]> Authored: Tue Apr 18 16:42:57 2017 +0800 Committer: Ahmet Altay <[email protected]> Committed: Tue Apr 18 09:32:43 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/runners/direct/executor.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/9697e8c2/sdks/python/apache_beam/runners/direct/executor.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/runners/direct/executor.py b/sdks/python/apache_beam/runners/direct/executor.py index da06158..53aa3d0 100644 --- a/sdks/python/apache_beam/runners/direct/executor.py +++ b/sdks/python/apache_beam/runners/direct/executor.py @@ -36,7 +36,7 @@ class ExecutorService(object): class CallableTask(object): - def __call__(self): + def call(self): pass @property @@ -83,7 +83,7 @@ class ExecutorService(object): try: if not self.shutdown_requested: self._update_name(task) - task() + task.call() self._update_name() finally: self.queue.task_done() @@ -261,7 +261,7 @@ class TransformExecutor(ExecutorService.CallableTask): self.blocked = False self._call_count = 0 - def __call__(self): + def call(self): self._call_count += 1 assert self._call_count <= (1 + len(self._applied_transform.side_inputs)) metrics_container = MetricsContainer(self._applied_transform.full_label) @@ -449,7 +449,7 @@ class _ExecutorServiceParallelExecutor(object): def name(self): return 'monitor' - def __call__(self): + def call(self): try: update = self._executor.all_updates.poll() while update:
