Commit 67b29bfc authored by Patrick Godwin's avatar Patrick Godwin

gstlal_ll_inspiral_pipe: patch up dagparts.groups -> groups in generating aggregator routes

parent 62d22f32
Pipeline #70794 passed with stages
in 21 minutes and 48 seconds
......@@ -569,7 +569,7 @@ agg_routes = list(itertools.chain(snr_routes, network_routes, usage_routes, stat
# FIXME don't hard code the 1000
max_agg_jobs = 1000
agg_job_bounds = range(0, len(jobTags), max_agg_jobs) + [max_agg_jobs]
agg_routes = list(dagparts.groups(agg_routes, max(max_agg_jobs // (4 * len(jobTags)), 1))) + ["far_history"]
agg_routes = list(groups(agg_routes, max(max_agg_jobs // (4 * len(jobTags)), 1))) + ["far_history"]
for routes in agg_routes:
these_options = dict(agg_options)
these_options["route"] = routes
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment