beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [2/3] incubator-beam git commit: Set end value in window.py and remove pylint disable statement.
Date Fri, 01 Jul 2016 17:50:48 GMT
Set end value in window.py and remove pylint disable statement.


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/833a4b6d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/833a4b6d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/833a4b6d

Branch: refs/heads/python-sdk
Commit: 833a4b6de34186b976a1ad6b0d6894dc3044a371
Parents: 2094e00
Author: Ahmet Altay <altay@google.com>
Authored: Fri Jul 1 10:28:38 2016 -0700
Committer: Ahmet Altay <altay@google.com>
Committed: Fri Jul 1 10:28:38 2016 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/transforms/window.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/833a4b6d/sdks/python/apache_beam/transforms/window.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/transforms/window.py b/sdks/python/apache_beam/transforms/window.py
index cc17bcf..eec89c0 100644
--- a/sdks/python/apache_beam/transforms/window.py
+++ b/sdks/python/apache_beam/transforms/window.py
@@ -367,9 +367,10 @@ class Sessions(WindowFn):
 
   def merge(self, merge_context):
     to_merge = []
+    end = timeutil.MIN_TIMESTAMP
     for w in sorted(merge_context.windows, key=lambda w: w.start):
       if to_merge:
-        if end > w.start:  # pylint: disable=used-before-assignment
+        if end > w.start:
           to_merge.append(w)
           if w.end > end:
             end = w.end


Mime
View raw message