Skip to content

Commit

Permalink
fixup! ✨ pyspark.sql.Column type
Browse files Browse the repository at this point in the history
  • Loading branch information
aguiddir committed Dec 7, 2023
1 parent 5b07c52 commit 85cfd66
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion datacompy/spark.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 85cfd66

Please sign in to comment.