Attention

This project is still in an early phase of development.

The python API is not yet stable, and some aspects of the schema for the blueprint and workplan will likely evolve. Therefore whilst you are welcome to try out using the package, we cannot yet guarantee backwards compatibility. We expect to reach a more stable version in 2026.

Orchestrator

class cstar.orchestration.orchestration.Orchestrator(planner: Planner, launcher: Launcher)

Bases: LoggingMixin

Manage the execution of a Workplan.

Methods

Orchestrator.get_closed_nodes(*, mode)	Retrieve the set of task nodes with a terminal state.
Orchestrator.get_open_nodes(*, mode)	Retrieve the set of task nodes with a non-terminal state that are executing or ready to execute.
Orchestrator.process_node(node)	Execute a task.
Orchestrator.run(mode)	Execute tasks that are ready and query status on running tasks.
Orchestrator.update_planner_state(n, task)	Update tracking information for the plan after starting a task or fetching an update.

Attributes

Orchestrator.log	Return the logger instance for this class.
Orchestrator.planner	The planner used by the orchestrator to prioritize tasks.
Orchestrator.launcher	The launcher used by the orchestrator to manage task execution.