diff --git a/sdks/python/apache_beam/transforms/sideinputs.py b/sdks/python/apache_beam/transforms/sideinputs.py index a38e05d66cbe..ac393c4c508d 100644 --- a/sdks/python/apache_beam/transforms/sideinputs.py +++ b/sdks/python/apache_beam/transforms/sideinputs.py @@ -31,6 +31,7 @@ from typing import TYPE_CHECKING from typing import Any +from apache_beam.coders import coder_impl from apache_beam.transforms import window if TYPE_CHECKING: @@ -110,3 +111,7 @@ def __iter__(self): def __reduce__(self): # Pickle self as an already filtered list. return list, (list(self), ) + + +coder_impl.FastPrimitivesCoderImpl.register_iterable_like_type( + _FilteringIterable)