Merge pull request #83 from XENONnT/read_chunk_length

read chunk lengths from rundoc

bin/bootstrax

@@ -115,7 +115,7 @@ args = parser.parse_args()
 # Configuration
 ##
 
-print(f'---\nTEST VERSION 0.3.3\n---')
+print(f'---\nTEST VERSION 0.3.5\n---')
 
 # The event builders write to different directories on the respective machines.
 eb_directories = {
@@ -749,7 +749,7 @@ def get_compressor(rd, default_compressor="blosc"):
 
 def run_strax(run_id, input_dir, target, n_readout_threads, compressor,
               run_start_time, samples_per_record, process_mode, is_LED,
-              debug=False):
+              daq_chunk_duration, daq_overlap_chunk_duration, debug=False):
     # Clear the swap memory used by npshmmex
     npshmex.shm_clear()
     # double check by forcefully clearing shm
@@ -777,6 +777,8 @@ def run_strax(run_id, input_dir, target, n_readout_threads, compressor,
                                 daq_compressor=compressor,
                                 run_start_time=run_start_time,
                                 record_length=samples_per_record,
+                                daq_chunk_duration = daq_chunk_duration,
+                                daq_overlap_chunk_duration = daq_overlap_chunk_duration,
                                 n_readout_threads=n_readout_threads,
                                 check_raw_record_overlaps=False,
                                 )
@@ -837,6 +839,12 @@ def process_run(rd, send_heartbeats=True):
 
         thread_info = rd.get('ini', dict()).get('processing_threads', dict())
         n_readout_threads = sum([v for v in thread_info.values()])
+        try:
+            daq_chunk_duration = int(rd['ini']['strax_chunk_length'] * 1e9)
+            daq_overlap_chunk_duration = int(rd['ini']['strax_chunk_overlap'] * 1e9)
+        except Exception as e:
+            fail(f"Could not find 'strax_chunk_length' and/or'strax_chunk_overlap' in "
+                 f"rundoc: {str(e)}")
 
         if not n_readout_threads:
             fail(f"Run doc for {run_id} has no readout thread count info")
@@ -883,6 +891,7 @@ def process_run(rd, send_heartbeats=True):
             target=run_strax,
             args=(run_id, loc, target, n_readout_threads, compressor,
                   run_start_time, samples_per_record, process_mode, is_LED,
+                  daq_chunk_duration, daq_overlap_chunk_duration,
                   args.debug))
 
         t0 = now()