From 278fa3723e400aaac2b3f83361152c53ae990ea2 Mon Sep 17 00:00:00 2001 From: liferoad Date: Wed, 17 Sep 2025 14:56:59 -0400 Subject: [PATCH] Add empty side_inputs tuple to MaybeReshuffle PTransform --- sdks/python/apache_beam/transforms/core.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sdks/python/apache_beam/transforms/core.py b/sdks/python/apache_beam/transforms/core.py index 1bfc732d13a3..543b56fe5b6b 100644 --- a/sdks/python/apache_beam/transforms/core.py +++ b/sdks/python/apache_beam/transforms/core.py @@ -4081,6 +4081,8 @@ def expand(self, pbegin): # transforms (e.g. Write). class MaybeReshuffle(PTransform): + side_inputs = () + def expand(self, pcoll): if len(serialized_values) > 1 and reshuffle: from apache_beam.transforms.util import Reshuffle