This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 5b8149a5783 Remove unused `reverse` argument in SmallestPerKey (#27621)
5b8149a5783 is described below
commit 5b8149a578316b00dfcd780462319dd47ac7f0c7
Author: Ruwann <[email protected]>
AuthorDate: Mon Aug 14 19:01:30 2023 +0200
Remove unused `reverse` argument in SmallestPerKey (#27621)
---
sdks/python/apache_beam/transforms/combiners.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/transforms/combiners.py
b/sdks/python/apache_beam/transforms/combiners.py
index 0ebf6982601..9fea1d6a4a9 100644
--- a/sdks/python/apache_beam/transforms/combiners.py
+++ b/sdks/python/apache_beam/transforms/combiners.py
@@ -317,7 +317,7 @@ class Top(object):
@staticmethod
@ptransform.ptransform_fn
- def SmallestPerKey(pcoll, n, *, key=None, reverse=None):
+ def SmallestPerKey(pcoll, n, *, key=None):
"""Identifies the N least elements associated with each key."""
return pcoll | Top.PerKey(n, key, reverse=True)
