This is an automated email from the ASF dual-hosted git repository.
damccorm 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 f8dbba156db Improve docstring for PGBKCVOperation (#37946)
f8dbba156db is described below
commit f8dbba156db35b1d16ee78ce0e76c7d725099017
Author: Subramanya V <[email protected]>
AuthorDate: Thu Mar 26 19:09:05 2026 +0530
Improve docstring for PGBKCVOperation (#37946)
* Improve docstring for PGBKCVOperation
* Fix docstring is satisfy lint
* Add costring for PGBKCVOperation
* Revert untended .gitignore changes
---
.../examples/snippets/transforms/aggregation/groupby_test.py | 1 -
sdks/python/apache_beam/runners/worker/operations.py | 5 +++++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git
a/sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_test.py
b/sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_test.py
index 0d2e5dfe25a..cc3fd5c3ccd 100644
---
a/sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_test.py
+++
b/sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_test.py
@@ -39,7 +39,6 @@ from .groupby_simple_aggregate import simple_aggregate
from .groupby_two_exprs import groupby_two_exprs
-
class UnorderedList(object):
def __init__(self, contents):
self._contents = list(contents)
diff --git a/sdks/python/apache_beam/runners/worker/operations.py
b/sdks/python/apache_beam/runners/worker/operations.py
index d0f7cceb558..f96eb372871 100644
--- a/sdks/python/apache_beam/runners/worker/operations.py
+++ b/sdks/python/apache_beam/runners/worker/operations.py
@@ -1234,6 +1234,11 @@ class PGBKOperation(Operation):
class PGBKCVOperation(Operation):
+ """Partial group-by-key operation.
+
+ This operation handles grouped values with
+a combine function applied.
+ """
def __init__(
self, name_context, spec, counter_factory, state_sampler,
windowing=None):
super(PGBKCVOperation,
