beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [1/2] beam git commit: Remove overloading of __call__ in DirectRunner
Date Tue, 18 Apr 2017 16:32:56 GMT
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 <ccy@google.com>
Authored: Tue Apr 18 16:42:57 2017 +0800
Committer: Ahmet Altay <altay@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:


Mime
View raw message