Skip to content
Snippets Groups Projects
Commit 17d57003 authored by Chad Hanna's avatar Chad Hanna
Browse files

gstlal_ll_inspiral_aggregator: update comments

parent c852fc26
No related branches found
No related tags found
No related merge requests found
......@@ -93,7 +93,7 @@ if __name__ == '__main__':
# First get the raw and reduced data for each job in parallel
mapargs = [(job, options.job_tag, routes, datatypes, prevdataspan, options.base_dir, jobs) for job in jobs]
for ds in pool.map(aggregator.get_data_from_job_and_reduce, mapargs):
#for ds in map(get_data_from_job_and_reduce, mapargs):
#for ds in map(aggregator.get_data_from_job_and_reduce, mapargs):
dataspan.update(ds)
prevdataspan = dataspan.copy()
# Then reduce the data across jobs at each level
......@@ -109,7 +109,7 @@ if __name__ == '__main__':
aggregator.setup_dir_across_job_by_level(start, typ, route, options.base_dir, verbose = True, level = level)
mapargs.append((jobs, this_level_dir, typ, route, func, level, start, end))
pool.map(aggregator.reduce_across_jobs, mapargs)
#map(reduce_across_jobs, mapargs)
#map(aggregator.reduce_across_jobs, mapargs)
#
# always end on an error so that condor won't think we're done and will
......
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