laborchestrator.engine.worker_observer module¶

This class observes running process steps. When delays or errors occur, jobs get finished the WFGManager, WorkerInterface or ScheduleManager are notified accordingly.

class laborchestrator.engine.worker_observer.WorkerObserver(wfg_manager: WFGManager, schedule_manager: ScheduleManager, jssp: SchedulingInstance, worker: WorkerInterface)[source]¶

Bases: object

_observe_protocol(step_id: str)[source]¶

is_delayed_significantly(job: ProcessStep) → Tuple[bool, float][source]¶

jssp: SchedulingInstance¶

observe()[source]¶: Master thread :return:

observed_jobs: Set[str]¶

schedule_manager: ScheduleManager¶

wfg_manager: WFGManager¶

worker: WorkerInterface¶