Task management for the task queue workers. The star of this show is TaskHandler, which is what turns base.Queue into a base.TaskQueue.

Be sure to call the TaskQueue.shutdown method (or that of your subclass, e.g., threads.ThreadQueue) before you shut down your Twisted reactor.

Class	Task	I represent a task that has been dispatched to a queue for running with a given scheduling niceness.
Class	TaskFactory	I generate `Task` instances with the right priority setting for effective scheduling between tasks in one or more concurrently running task series.
Class	Assignment	I represent the assignment of a single task to whichever worker object accepts me. Deep down, my real role is to provide something to fire the callback of a deferred with instead of just another deferred.
Class	AssignmentFactory	I generate `Assignment` instances for workers to handle particular tasks.
Class	TaskHandler	I am a Queue handler that manages one or more providers of `IWorker`.

API Documentation for AsynQueue, generated by pydoctor at 2022-11-17 13:13:24.

asynqueue.tasks module documentation

`asynqueue.tasks` module documentation