Skip to content
Snippets Groups Projects
Commit 5ef1fe09 authored by chad.hanna's avatar chad.hanna Committed by Kipp Cannon
Browse files

gstlal_ll_inspiral_state: improve tmp file use

parent 7f7f9283
No related branches found
No related tags found
No related merge requests found
......@@ -81,8 +81,8 @@ def get_data_from_route((job, job_tag, routes, basedir)):
data = aggregator.get_url(url, route)
jobtime, jobdata = data[0], data[1]
path = "%s/by_job/%s" % (basedir, job)
fname = aggregator.create_new_dataset(path, route.replace("/","_"), timedata = jobtime, data = jobdata, tmp = True)
shutil.move(fname, fname.replace(".tmp", ""))
tmpfname, fname = aggregator.create_new_dataset(path, route.replace("/","_"), timedata = jobtime, data = jobdata, tmp = True)
shutil.move(tmpfname, fname)
if __name__ == '__main__':
......@@ -123,8 +123,8 @@ if __name__ == '__main__':
# FIXME hack to adjust for 16 Hz sample rate of ALIGO vs 1 Hz of Virgo
datadata[(job,route)] /= 16
path = "%s/by_job/%s" % (options.base_dir, job)
fname = aggregator.create_new_dataset(path, route.replace("/","_"), timedata = timedata[(job,route)], data = datadata[(job,route)], tmp = True)
shutil.move(fname, fname.replace(".tmp", ""))
tmpfname, fname = aggregator.create_new_dataset(path, route.replace("/","_"), timedata = timedata[(job,route)], data = datadata[(job,route)], tmp = True)
shutil.move(tmpfname, fname)
else:
mapargs = [(job, options.job_tag, routes, options.base_dir) for job in jobs]
pool.map(get_data_from_route, mapargs)
......
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