(self, lazy=False,
extension_namespace='celery.beat_schedulers')
| 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'): |
| 668 | filename = self.schedule_filename |
| 669 | aliases = dict(load_extension_class_names(extension_namespace)) |
| 670 | return symbol_by_name(self.scheduler_cls, aliases=aliases)( |
| 671 | app=self.app, |
| 672 | schedule_filename=filename, |
| 673 | max_interval=self.max_interval, |
| 674 | lazy=lazy, |
| 675 | ) |
| 676 | |
| 677 | @cached_property |
| 678 | def scheduler(self): |
nothing calls this directly
no test coverage detected