We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5b4f915 commit b5bfa48Copy full SHA for b5bfa48
1 file changed
emm/preprocessing/pandas_preprocessor.py
@@ -116,8 +116,8 @@ def _spark_apply_steps(
116
sc = self.spark_session.sparkContext
117
rdd = sc.parallelize(X_chunks, len(X_chunks))
118
119
- def calc(chunk, funcs):
120
- for func in funcs:
+ def calc(chunk, functions):
+ for func in functions:
121
chunk = func(chunk)
122
return chunk.index.values, chunk.values
123
0 commit comments