Skip to content

Commit

Permalink
Merge pull request #3 from lsst-camera-dh/LSSTTD-905
Browse files Browse the repository at this point in the history
Fix persistence of analysis job data products
  • Loading branch information
jchiang87 authored Feb 21, 2017
2 parents 4683e2b + d2084c2 commit 5b546d0
Show file tree
Hide file tree
Showing 5 changed files with 7 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -115,5 +115,5 @@ def slot_dependency_glob(pattern, jobname):
plt.savefig('%s_psf_sigma.png' % raft_id)

bar_charts.make_multi_bar_chart(('GAIN', 'PTC_GAIN'), 'System Gain (e-/ADU)',
title=raft_id, colors='br')
title=raft_id, colors='br', ylog=True)
plt.savefig('%s_system_gain.png' % raft_id)
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,8 @@
slot=slot,
sensor_id=sensor_id))

results.extend([lcatr.schema.fileref.make(x) for x in output_files])

results.extend(siteUtils.jobInfo())
lcatr.schema.write_file(results)
lcatr.schema.validate_file()
2 changes: 1 addition & 1 deletion harnessed_jobs/prnu_raft/v0/validator_prnu_raft.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@

qe_acq_job_id = \
siteUtils.get_prerequisite_job_id('S*/%s_lambda_flat_*.fits' % sensor_id,
jobname='qe_raft_acq_sim')
jobname=siteUtils.getProcessName('qe_raft_acq'))
md = dict(illumination_non_uniformity_file=dict(JOB_ID=qe_acq_job_id))
results.extend(eotestUtils.eotestCalibsPersist('illumination_non_uniformity_file',
metadata=md))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
band=band, QE=np.mean(QE[band]),
slot=slot, sensor_id=sensor_id))

qe_files = glob.glob('*QE*.*')
qe_files = glob.glob('%s_*QE*.*' % sensor_id)
for item in qe_files:
if item.endswith('.fits'):
eotestUtils.addHeaderData(item, LSST_NUM=sensor_id,
Expand All @@ -49,7 +49,7 @@
sensor_id = raft.sensor_names[0]
qe_acq_job_id = siteUtils.get_prerequisite_job_id(('S*/%s_lambda_flat_*.fits'
% sensor_id),
jobname='qe_raft_acq_sim')
jobname=siteUtils.getProcessName('qe_raft_acq'))
md = dict(photodiode_ratio_file=dict(JOB_ID=qe_acq_job_id),
illumination_non_uniformity_file=dict(JOB_ID=qe_acq_job_id))

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
sensor_id=sensor_id))

fe55_acq_job_id = siteUtils.get_prerequisite_job_id('S*/%s_fe55_fe55_*.fits' % sensor_id,
jobname='fe55_raft_acq_sim')
jobname=siteUtils.getProcessName('fe55_raft_acq'))

files = glob.glob('%s_read_noise?*.fits' % sensor_id)
for fitsfile in files:
Expand Down

0 comments on commit 5b546d0

Please sign in to comment.