mut bug

rust/worker/src/execution/operators/pull_log.rs

@@ -123,8 +123,9 @@ impl Operator<PullLogsInput, PullLogsOutput> for PullLogsOperator {
             offset += batch_size as i64;
             result.append(&mut logs);
 
-            // We used a a timestamp and we didn't get a full batch, so we are done
-            if input.end_timestamp.is_some() && logs.len() < batch_size as usize {
+            // We used a a timestamp and we didn't get a full batch, so we have retrieved
+            // the last batch of logs relevant to our query
+            if input.end_timestamp.is_some() && num_records_read < batch_size as usize {
                 break;
             }