merged check-databriks -> feat/refactoring

wednesday-solutions · Dec 13, 2023 · f137268 · f137268
2 parents 99cc493 + 10a0eff
commit f137268
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/app/spark_wrapper.py b/app/spark_wrapper.py
@@ -2,7 +2,7 @@
 from pyspark.sql import Window, WindowSpec
 
 
-def create_frame(sc: SparkSession, path: str):
+def create_frame(sc, path: str):
     df = sc.read.csv(path, inferSchema=True, header=True)
     return df