Garmelon/pasch
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Allow configuring and executing manually

Browse source
This commit is contained in:
Joscha 2026-02-18 12:03:07 +01:00
parent 034d56b733
commit 8481026b39
1 changed files with 15 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

16
pasch/orchestrator.py
View file

@ -62,6 +62,7 @@ class Orchestrator:
self.host = socket.gethostname() self.host = socket.gethostname()
self._frozen: bool = False self._frozen: bool = False
self._configured: bool = False
self._modules: list[Module] = [] self._modules: list[Module] = []
def register(self, module: Module) -> None: def register(self, module: Module) -> None:
@ -69,7 +70,10 @@ class Orchestrator:
raise Exception("registering module wile orchestrator is frozen") raise Exception("registering module wile orchestrator is frozen")
self._modules.append(module) self._modules.append(module)
def realize(self) -> None: def configure(self) -> None:
if self._configured:
raise Exception("reconfiguring a configured orchestrator")
self._frozen = True self._frozen = True
self.c.print() self.c.print()
@ -78,8 +82,18 @@ class Orchestrator:
self.c.print(f"[bold bright_magenta]\\[{escape(type(module).__name__)}]") self.c.print(f"[bold bright_magenta]\\[{escape(type(module).__name__)}]")
module.configure() module.configure()
self._configured = True
def execute(self) -> None:
if not self._configured:
raise Exception("executing an unconfigured orchestrator")
self.c.print() self.c.print()
self.c.print("[bold bright_cyan]# Execute") self.c.print("[bold bright_cyan]# Execute")
for module in self._modules: for module in self._modules:
self.c.print(f"[bold bright_magenta]\\[{escape(type(module).__name__)}]") self.c.print(f"[bold bright_magenta]\\[{escape(type(module).__name__)}]")
module.execute() module.execute()
def realize(self) -> None:
self.configure()
self.execute()