Skip to content
Snippets Groups Projects

[REMI][Correct] Propagate train timestamps to output files

Merged Thomas Kluyver requested to merge fix/remi-propagate-timestamps into master
All threads resolved!
1 file
+ 5
2
Compare changes
  • Side-by-side
  • Inline
import pasha as psh
import pasha as psh
from euxfel_bunch_pattern import indices_at_sase, indices_at_laser
from euxfel_bunch_pattern import indices_at_sase, indices_at_laser
from extra_data import RunDirectory
from extra_data import RunDirectory, by_id
from extra_remi import Analysis, trigger_dt
from extra_remi import Analysis, trigger_dt
from extra_remi.util import timing
from extra_remi.util import timing
from extra_remi.rd_resort import signal_dt, hit_dt
from extra_remi.rd_resort import signal_dt, hit_dt
with DataFile.from_details(out_folder, out_aggregator, run, seq_id) as outp:
with DataFile.from_details(out_folder, out_aggregator, run, seq_id) as outp:
outp.create_metadata(like=dc, proposal=proposal, run=run, sequence=seq_id,
outp.create_metadata(like=dc, proposal=proposal, run=run, sequence=seq_id,
control_sources=control_sources, instrument_channels=instrument_channels)
control_sources=control_sources, instrument_channels=instrument_channels)
outp.create_index(seq_train_ids)
outp.create_index(
 
seq_train_ids,
 
timestamps=dc.select_trains(by_id[seq_train_ids]).train_timestamps().astype(np.uint64)
 
)
for det_name in remi['detector']:
for det_name in remi['detector']:
cur_device_id = det_device_id.format(karabo_id=karabo_id, det_name=det_name.upper())
cur_device_id = det_device_id.format(karabo_id=karabo_id, det_name=det_name.upper())
Loading