Method
record_query_batch
(self, batch_size, batch_duration, failed_count=0)
Source from the content-addressed store, hash-verified
| 160 | self.failed_queries = 0 |
| 161 | |
| 162 | def record_query_batch(self, batch_size, batch_duration, failed_count=0): |
| 163 | with self.lock: |
| 164 | self.total_queries += batch_size |
| 165 | self.failed_queries += failed_count |
| 166 | avg_query_time = batch_duration / batch_size if batch_size > 0 else 0 |
| 167 | self.query_times.extend([avg_query_time] * (batch_size - failed_count)) |
| 168 | |
| 169 | def stop_tracking(self): |
| 170 | self.end_time = time.time() |
Tested by
no test coverage detected