Add file to pending set and reset the debounce timer.
(self, abs_path: str)
| 1138 | logger.error("Error removing %s: %s", rel, e) |
| 1139 | |
| 1140 | def _schedule(self, abs_path: str): |
| 1141 | """Add file to pending set and reset the debounce timer.""" |
| 1142 | with self._lock: |
| 1143 | self._pending.add(abs_path) |
| 1144 | if self._timer is not None: |
| 1145 | self._timer.cancel() |
| 1146 | self._timer = threading.Timer(_DEBOUNCE_SECONDS, self._flush) |
| 1147 | self._timer.start() |
| 1148 | |
| 1149 | def _flush(self): |
| 1150 | """Process all pending files after the debounce window.""" |
no test coverage detected