(self, wait=False)
| 659 | self._is_stopped.set() |
| 660 | |
| 661 | def stop(self, wait=False): |
| 662 | info('beat: Shutting down...') |
| 663 | self._is_shutdown.set() |
| 664 | wait and self._is_stopped.wait() # block until shutdown done. |
| 665 | |
| 666 | def get_scheduler(self, lazy=False, |
| 667 | extension_namespace='celery.beat_schedulers'): |