diff --git a/saltax/plugins/s_raw_records.py b/saltax/plugins/s_raw_records.py index 37a3d1b..5505741 100644 --- a/saltax/plugins/s_raw_records.py +++ b/saltax/plugins/s_raw_records.py @@ -11,6 +11,8 @@ log = logging.getLogger('wfsim.interface') log.setLevel('WARNING') +NS_NO_INSTRUCTION_BEFORE_CHUNK_END = 5e7 + @export class ChunkRawRecords(object): """ @@ -228,7 +230,7 @@ def compute(self, raw_records, start, end): self.sim = ChunkRawRecords(self.config) instructions = self.instructions instructions = instructions[(instructions['time'] >= start) & - (instructions['time'] < end)] # Probably need safeguard here + (instructions['time'] < end-NS_NO_INSTRUCTION_BEFORE_CHUNK_END)] self.sim_iter = self.sim(instructions) try: result = next(self.sim_iter)