Scheduler

class atqo.Scheduler(actor_dict: dict[CapabilitySet, type[ActorBase] | partial], resource_limits: dict[Enum, float], distributed_system: str = 'sync', verbose=False)

Bases: object

Attributes Summary

`is_empty`
`is_idle`
`queued_task_count`

Methods Summary

`cleanup`()
`iter_until_n_tasks_remain`([remaining_tasks])
`join`()
`process`(batch_producer[, min_queue_size])
`refill_task_queue`(task_batch)

Attributes Documentation

is_empty

is_idle

queued_task_count

Methods Documentation

cleanup()

iter_until_n_tasks_remain(remaining_tasks: int = 0)

join()

process(batch_producer: Callable[[], list[SchedulerTask]], min_queue_size: int = 0)

refill_task_queue(task_batch: Iterable[SchedulerTask])