Skip to content

Commit cc1da9f

Browse files
lgraylgray
authored andcommitted
remove postprocessing mods, not needed
1 parent 9b5f36a commit cc1da9f

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

fnal_column_analysis_tools/processor/executor.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,7 @@ def run_parsl_job(fileset, treename, processor_instance, executor, data_flow=Non
181181

182182

183183
def run_spark_job(fileset, processor_instance, executor, executor_args={'config': None},
184-
postprocessing_mods=[], spark=None, partitionsize=200000, thread_workers=16):
184+
spark=None, partitionsize=200000, thread_workers=16):
185185
'''
186186
A convenience wrapper to submit jobs for spark datasets, which is a
187187
dictionary of dataset: [file list] entries. Presently supports reading of
@@ -221,8 +221,6 @@ def run_spark_job(fileset, processor_instance, executor, executor_args={'config'
221221

222222
if not isinstance(fileset, Mapping):
223223
raise ValueError("Expected fileset to be a mapping dataset: list(files)")
224-
if not isinstance(postprocessing_mods, Sequence):
225-
raise ValueError("Expected postprocessing modifiers to be a list: list(functions)")
226224
if not isinstance(processor_instance, ProcessorABC):
227225
raise ValueError("Expected processor_instance to derive from ProcessorABC")
228226
if not isinstance(executor, SparkExecutor):

0 commit comments

Comments
 (0)