| 703 | _Process = None |
| 704 | else: |
| 705 | class _Process(Process): |
| 706 | |
| 707 | def __init__(self, app, **kwargs): |
| 708 | super().__init__() |
| 709 | self.app = app |
| 710 | self.service = Service(app, **kwargs) |
| 711 | self.name = 'Beat' |
| 712 | |
| 713 | def run(self): |
| 714 | reset_signals(full=False) |
| 715 | platforms.close_open_fds([ |
| 716 | sys.__stdin__, sys.__stdout__, sys.__stderr__, |
| 717 | ] + list(iter_open_logger_fds())) |
| 718 | self.app.set_default() |
| 719 | self.app.set_current() |
| 720 | self.service.start(embedded_process=True) |
| 721 | |
| 722 | def stop(self): |
| 723 | self.service.stop() |
| 724 | self.terminate() |
| 725 | |
| 726 | |
| 727 | def EmbeddedService(app, max_interval=None, **kwargs): |