diff --git a/sdks/python/apache_beam/typehints/native_type_compatibility.py b/sdks/python/apache_beam/typehints/native_type_compatibility.py index 00172a9d453e..5137a83716b6 100644 --- a/sdks/python/apache_beam/typehints/native_type_compatibility.py +++ b/sdks/python/apache_beam/typehints/native_type_compatibility.py @@ -292,7 +292,7 @@ class TypedWindowedValue(Generic[T]): def __init__(self, *args, **kwargs): raise NotImplementedError("This class is solely for type inference") - + def convert_to_beam_type(typ): """Convert a given typing type to a Beam type. @@ -347,7 +347,7 @@ def convert_to_beam_type(typ): # to the correct type constraint in Beam # This is needed to fix https://github.com/apache/beam/issues/33356 pass - + elif (typ_module != 'typing') and (typ_module != 'collections.abc') and not is_builtin(typ): # Only translate primatives and types from collections.abc and typing.