towhee.engine.task_scheduler.TaskScheduler

class towhee.engine.task_scheduler.TaskScheduler(task_execs: List[ThreadPoolTaskExecutor])

Bases: ABC

Task scheduler abstract interface.

Parameters:

task_execs – (List[towhee.TaskExecutor]) A list of task executors that the Engine manages. Also should be continuously changing as new executors are acquired.

Methods

join
schedule_forever	Runs the a single schedule step in a loop.
schedule_step
stop

__init__(task_execs: List[ThreadPoolTaskExecutor])

schedule_forever(sleep_ms)

Runs the a single schedule step in a loop.

sleep_ms: (int)

Milliseconds to sleep after completing a single scheduling step.