diff --git a/emm/preprocessing/pandas_preprocessor.py b/emm/preprocessing/pandas_preprocessor.py index 3ab04ab..bdda7bd 100644 --- a/emm/preprocessing/pandas_preprocessor.py +++ b/emm/preprocessing/pandas_preprocessor.py @@ -116,8 +116,8 @@ def _spark_apply_steps( sc = self.spark_session.sparkContext rdd = sc.parallelize(X_chunks, len(X_chunks)) - def calc(chunk, funcs): - for func in funcs: + def calc(chunk, functions): + for func in functions: chunk = func(chunk) return chunk.index.values, chunk.values