You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/04/18 16:32:56 UTC
[1/2] beam git commit: Remove overloading of __call__ in DirectRunner
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 <cc...@google.com>
Authored: Tue Apr 18 16:42:57 2017 +0800
Committer: Ahmet Altay <al...@google.com>
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:
[2/2] beam git commit: This closes #2571
Posted by al...@apache.org.
This closes #2571
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/034bcb4e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/034bcb4e
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/034bcb4e
Branch: refs/heads/master
Commit: 034bcb4e2a2ee59c1a9bf16690547765064327e2
Parents: d4ce94f 9697e8c
Author: Ahmet Altay <al...@google.com>
Authored: Tue Apr 18 09:32:47 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Tue Apr 18 09:32:47 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/runners/direct/executor.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------