(self)
| 71 | self._process = None |
| 72 | self._is_running = False |
| 73 | async def status(self): |
| 74 | return { |
| 75 | "is_running": (self._is_running or self._is_starting) and self._process is not None, |
| 76 | } |
| 77 | |
| 78 | def subscribe(self): |
| 79 | return self._output_queue # return the queue for external subscription |