Skip to content

Commit 27ad139

Browse files
authored
Allow passing label through GBK (#36426)
1 parent d19b534 commit 27ad139

File tree

1 file changed

+2
-1
lines changed
  • sdks/python/apache_beam/transforms

1 file changed

+2
-1
lines changed

sdks/python/apache_beam/transforms/core.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3335,9 +3335,10 @@ class GroupByKey(PTransform):
33353335
33363336
The implementation here is used only when run on the local direct runner.
33373337
"""
3338-
def __init__(self):
3338+
def __init__(self, label=None):
33393339
self._replaced_by_gbek = False
33403340
self._inside_gbek = False
3341+
super().__init__(label)
33413342

33423343
class ReifyWindows(DoFn):
33433344
def process(

0 commit comments

Comments
 (0)