Repository: beam Updated Branches: refs/heads/master c79bd95bd -> 388b82e8b
[BEAM-1635] TypeError in AfterWatermark class's __repr__ method Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/21700da2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/21700da2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/21700da2 Branch: refs/heads/master Commit: 21700da27e1a796b2d8ead4228b8eb15befcaafc Parents: c79bd95 Author: Tibor Kiss <[email protected]> Authored: Tue Mar 7 04:00:24 2017 -0800 Committer: Ahmet Altay <[email protected]> Committed: Tue Mar 7 09:07:48 2017 -0800 ---------------------------------------------------------------------- sdks/python/apache_beam/transforms/trigger.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/21700da2/sdks/python/apache_beam/transforms/trigger.py ---------------------------------------------------------------------- diff --git a/sdks/python/apache_beam/transforms/trigger.py b/sdks/python/apache_beam/transforms/trigger.py index 8c23873..69a35ae 100644 --- a/sdks/python/apache_beam/transforms/trigger.py +++ b/sdks/python/apache_beam/transforms/trigger.py @@ -237,7 +237,7 @@ class AfterWatermark(TriggerFn): if self.early: qualifiers.append('early=%s' % self.early) if self.late: - qualifiers.append('late=%s', self.late) + qualifiers.append('late=%s' % self.late) return 'AfterWatermark(%s)' % ', '.join(qualifiers) def is_late(self, context):
