Orchestrator class

The Taipy Orchestrator service.

When run, the Orchestrator starts a job dispatcher which is responsible for dispatching the submitted jobs to an available executor for their execution.

Configuration update

The Orchestrator service blocks the Config from updates while running.

Methods

__init__()

__init__() -> None

Initialize an Orchestrator service.

run()

run(force_restart=False) -> None

Start the Orchestrator service.

This function checks and locks the configuration, manages application's version, and starts a job dispatcher.

stop()

stop(
    wait: bool = True, timeout: Optional[float] = None
) -> None

Stop the Orchestrator service. This function stops the dispatcher and unblock the Config for update.

Parameters:

Name	Type	Description	Default
wait	bool	If True, the method will wait for the dispatcher to stop.	True
timeout	Optional[float]	The maximum time to wait. If None, the method will wait indefinitely.	None