From 264fffda89e829786e3abbb55d77b2ca21d0c41e Mon Sep 17 00:00:00 2001 From: Ally Franken Date: Tue, 21 Jan 2025 16:09:44 -0500 Subject: [PATCH] reformat with ruff format --- datacompy/spark/helper.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/datacompy/spark/helper.py b/datacompy/spark/helper.py index 9d1c4ac..7a705ea 100644 --- a/datacompy/spark/helper.py +++ b/datacompy/spark/helper.py @@ -102,7 +102,7 @@ def detailed_compare( def handle_numeric_strings( - df: "pyspark.sql.DataFrame", field_list: list + df: "pyspark.sql.DataFrame", field_list: list ) -> "pyspark.sql.DataFrame": """Convert columns in field_list from numeric strings to DoubleType. @@ -122,7 +122,9 @@ def handle_numeric_strings( return df -def sort_rows(base_df: "pyspark.sql.DataFrame", compare_df: "pyspark.sql.DataFrame") -> "pyspark.sql.DataFrame": +def sort_rows( + base_df: "pyspark.sql.DataFrame", compare_df: "pyspark.sql.DataFrame" +) -> "pyspark.sql.DataFrame": """Add new column to each DataFrame that numbers the rows, so they can be compared by row number. Parameters @@ -161,7 +163,9 @@ def sort_rows(base_df: "pyspark.sql.DataFrame", compare_df: "pyspark.sql.DataFra return sorted_base_df, sorted_compare_df -def sort_columns(base_df: "pyspark.sql.DataFrame", compare_df: "pyspark.sql.DataFrame") -> "pyspark.sql.DataFrame": +def sort_columns( + base_df: "pyspark.sql.DataFrame", compare_df: "pyspark.sql.DataFrame" +) -> "pyspark.sql.DataFrame": """Sort both DataFrames by their columns to ensure consistent order. Parameters