fix beam_monitor event stream read method
Unit Testing / test (3.10) (push) Failing after 24s
Unit Testing / test (3.12) (push) Failing after 19s
Unit Testing / test (3.8) (push) Failing after 17s
Unit Testing / test (3.11) (push) Failing after 21s
Unit Testing / test (3.9) (push) Failing after 12m26s
Unit Testing / test (3.10) (push) Failing after 24s
Unit Testing / test (3.12) (push) Failing after 19s
Unit Testing / test (3.8) (push) Failing after 17s
Unit Testing / test (3.11) (push) Failing after 21s
Unit Testing / test (3.9) (push) Failing after 12m26s
This commit is contained in:
@@ -194,7 +194,7 @@ class ApplyMask(EventDataAction):
|
||||
fltr = (d.events.mask & (~self.bitmask_filter)) == 0
|
||||
d.events = d.events[fltr]
|
||||
post_filter = d.events.shape[0]
|
||||
logging.info(f' number of events: total = {pre_filter:7d}, filtered = {post_filter:7d}')
|
||||
logging.info(f' number of events: total = {pre_filter:7d}, after filtering = {post_filter:7d}')
|
||||
if d.device_logs == {} or not hasattr(dataset, 'update_info_from_logs'):
|
||||
return
|
||||
# filter pulses and logs to allow update of header information
|
||||
|
||||
+1
-1
@@ -459,7 +459,7 @@ class AmorEventData(AmorHeader):
|
||||
self._beam_monitor = self.rv('beam_monitor', default=None)
|
||||
pulses = self.read_chopper_trigger_stream(packets)
|
||||
current = self.read_proton_current_stream(packets)
|
||||
beam_monitor = self.read_proton_current_stream(packets)
|
||||
beam_monitor = self.read_beam_monitor_stream(packets)
|
||||
|
||||
# read parameter logs not present in old files to ensure they are in self._log_keys if they exist
|
||||
_acquisition_filter = self.rv('acquisition_filter', default=None)
|
||||
|
||||
Reference in New Issue
Block a user