Update progress with number of items processed
(self, items_processed: int, errors: int = 0)
| 31 | self.report_interval = 10 # Report every 10 seconds |
| 32 | |
| 33 | def update(self, items_processed: int, errors: int = 0): |
| 34 | """Update progress with number of items processed""" |
| 35 | self.processed_items += items_processed |
| 36 | self.errors_encountered += errors |
| 37 | |
| 38 | current_time = time.time() |
| 39 | if current_time - self.last_report_time >= self.report_interval: |
| 40 | self._report_progress() |
| 41 | self.last_report_time = current_time |
| 42 | |
| 43 | def _report_progress(self): |
| 44 | """Report current progress""" |
no test coverage detected