Invalidate and stop any pending delayed flush timer.
(self)
| 159 | logger.exception("Error migrating legacy option '%s'", old_option) |
| 160 | |
| 161 | def __cancel_flush_timer(self): |
| 162 | """Invalidate and stop any pending delayed flush timer.""" |
| 163 | self._flush_generation += 1 |
| 164 | timer = self._flush_timer |
| 165 | self._flush_timer = None |
| 166 | if timer is not None: |
| 167 | timer.cancel() |
| 168 | |
| 169 | def __flush_after_delay(self, generation): |
| 170 | """Timer callback that flushes if the timer is still current.""" |