Skip to content
Snippets Groups Projects
Commit ec8ec872 authored by Patrick Godwin's avatar Patrick Godwin
Browse files

gstlal_ll_feature_extractor_pipe: remove nonexistent option causing crashes in aggregator jobs

parent 184bd89e
No related branches found
No related tags found
No related merge requests found
......@@ -422,7 +422,7 @@ if options.save_format == 'kafka':
all_fx_jobs = [(str(ii).zfill(4), channel_subset) for ii, channel_subset in enumerate(data_source_info.channel_subsets)]
for job_subset in groups(all_fx_jobs, options.num_agg_jobs):
jobs, channels = zip(*job_subset)
job_channel_options = {"jobs": jobs, "num-channels": len(channels)}
job_channel_options = {"jobs": jobs}
job_channel_options.update(aggregator_options)
agg_node = dagparts.DAGNode(aggregator_job, dag, [], opts = job_channel_options, output_files = {"rootdir": os.path.join(options.out_path, "aggregator")})
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment