tvalentyn commented on code in PR #24834:
URL: https://github.com/apache/beam/pull/24834#discussion_r1081983122
##
sdks/python/apache_beam/transforms/util.py:
##
@@ -234,7 +234,8 @@ def expand(self, pcolls):
for pcoll in pcolls.values():
self._check_pcollection(pcoll
tvalentyn commented on code in PR #24834:
URL: https://github.com/apache/beam/pull/24834#discussion_r1081979119
##
sdks/python/apache_beam/transforms/util.py:
##
@@ -234,7 +234,8 @@ def expand(self, pcolls):
for pcoll in pcolls.values():
self._check_pcollection(pcoll