We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d19b534 commit 27ad139Copy full SHA for 27ad139
1 file changed
sdks/python/apache_beam/transforms/core.py
@@ -3335,9 +3335,10 @@ class GroupByKey(PTransform):
3335
3336
The implementation here is used only when run on the local direct runner.
3337
"""
3338
- def __init__(self):
+ def __init__(self, label=None):
3339
self._replaced_by_gbek = False
3340
self._inside_gbek = False
3341
+ super().__init__(label)
3342
3343
class ReifyWindows(DoFn):
3344
def process(
0 commit comments