From c6436458f2828ea7f63936fb4939e68e736ea7a6 Mon Sep 17 00:00:00 2001 From: Jack McCluskey Date: Wed, 13 Nov 2024 11:13:21 -0500 Subject: [PATCH] fix imports --- sdks/python/apache_beam/dataframe/transforms.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/sdks/python/apache_beam/dataframe/transforms.py b/sdks/python/apache_beam/dataframe/transforms.py index c8ac8174232d..8f27ce95c294 100644 --- a/sdks/python/apache_beam/dataframe/transforms.py +++ b/sdks/python/apache_beam/dataframe/transforms.py @@ -17,7 +17,6 @@ import collections import logging from collections.abc import Mapping -from typing import TYPE_CHECKING from typing import Any from typing import TypeVar from typing import Union @@ -29,16 +28,13 @@ from apache_beam.dataframe import expressions from apache_beam.dataframe import frames # pylint: disable=unused-import from apache_beam.dataframe import partitionings +from apache_beam.pvalue import PCollection from apache_beam.utils import windowed_value __all__ = [ 'DataframeTransform', ] -if TYPE_CHECKING: - # pylint: disable=ungrouped-imports - from apache_beam.pvalue import PCollection - T = TypeVar('T') TARGET_PARTITION_SIZE = 1 << 23 # 8M