process_orchestrator.py

from multiprocessing import Process


# A simple process manager to control a single daemon at a time.
class Orchestrator:
    def __init__(self) -> None:
        self._current_process = None
        pass

    def schedule(self, thread: Process) -> bool:
        if self._current_process is not None:
            return False

        self._current_process = thread

        self._current_process.daemon = True
        self._current_process.start()
        return True

    def get_current_process(self) -> Process | None:
        return self._current_process

    def kill_process(self):
        if self._current_process is not None:
            self._current_process.terminate()
        self._current_process = None

    def thread_join(self):
        self._current_process.join()