towhee.engine.task_scheduler.TaskScheduler¶
- class towhee.engine.task_scheduler.TaskScheduler(task_execs: List[ThreadPoolTaskExecutor])[source]¶
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
Runs the a single schedule step in a loop.
schedule_step
stop
- __init__(task_execs: List[ThreadPoolTaskExecutor])[source]¶