From 85cfd66c7539bb5fe01d61dc9a41bdad9593c18d Mon Sep 17 00:00:00 2001 From: aguiddir Date: Thu, 7 Dec 2023 22:07:01 +0100 Subject: [PATCH] =?UTF-8?q?fixup!=20=E2=9C=A8=20pyspark.sql.Column=20type?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- datacompy/spark.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datacompy/spark.py b/datacompy/spark.py index 035aa876..53599bd0 100644 --- a/datacompy/spark.py +++ b/datacompy/spark.py @@ -543,7 +543,7 @@ def _populate_columns_match_dict(self) -> None: *self.columns_compared ) - def helper(c: str) -> pyspark.sql.Column: + def helper(c: str) -> "pyspark.sql.Column": # Create a predicate for each match type, comparing column values to the match type value predicates = [F.col(c) == k.value for k in MatchType] # Create a tuple(number of match types found for each match type in this column)