API

atqo Package

Async Task Queue Orchestrator with Complex Resource Management

Functions

acquire_lock(lock_id)
get_lock(lock_id)
parallel_consume(Actor, iterable[, ...])
parallel_map(fun, iterable[, dist_api, ...])

Classes

ActorBase()
Capability(resource_needs[, name])
CapabilitySet
DistAPIBase()
Scheduler(actor_dict, resource_limits[, ...])
SchedulerTask(argument[, requirements, ...])
TaskPropertyBase()
UnexpectedCapabilities

Class Inheritance Diagram

digraph inheritance054e1ae539 { bgcolor=transparent; rankdir=LR; size="8.0, 12.0"; "ABC" [fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",tooltip="Helper class that provides a standard way to create an ABC using"]; "ActorBase" [URL="api/atqo.ActorBase.html#atqo.ActorBase",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "ABC" -> "ActorBase" [arrowsize=0.5,style="setlinewidth(0.5)"]; "Capability" [URL="api/atqo.Capability.html#atqo.Capability",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "CapabilitySet" [URL="api/atqo.CapabilitySet.html#atqo.CapabilitySet",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "DistAPIBase" [URL="api/atqo.DistAPIBase.html#atqo.DistAPIBase",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "ABC" -> "DistAPIBase" [arrowsize=0.5,style="setlinewidth(0.5)"]; "Scheduler" [URL="api/atqo.Scheduler.html#atqo.Scheduler",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "SchedulerTask" [URL="api/atqo.SchedulerTask.html#atqo.SchedulerTask",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "TaskPropertyBase" [URL="api/atqo.TaskPropertyBase.html#atqo.TaskPropertyBase",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; "UnexpectedCapabilities" [URL="api/atqo.UnexpectedCapabilities.html#atqo.UnexpectedCapabilities",fillcolor=white,fontname="Vera Sans, DejaVu Sans, Liberation Sans, Arial, Helvetica, sans",fontsize=10,height=0.25,shape=box,style="setlinewidth(0.5),filled",target="_top"]; }