wei.core.scheduler

Handles scheduling workflows and executing steps on the workcell.

Classes

Scheduler([sequential])

Handles scheduling workflow steps on the workcell.

class wei.core.scheduler.Scheduler(sequential: bool = False)

Handles scheduling workflow steps on the workcell.

__init__(sequential: bool = False) → None

Initializes the scheduler.

run_iteration() → None

Runs a single iteration of the scheduler, checking each workflow to see if it is able to run. If a workflow is able to run, it is started in a separate process. Workflows are processed in the order they are received, so older workflows have priority.