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.

Instance Variable d A Deferred that is instantiated for a given instance of me, which fires when a worker accepts the assigment represented by that instance.
Method __init__ Undocumented
Method accept Called when the worker accepts the assignment, firing my Deferred.
d =
A Deferred that is instantiated for a given instance of me, which fires when a worker accepts the assigment represented by that instance.
def __init__(self, task):
Undocumented
def accept(self, worker):

Called when the worker accepts the assignment, firing my Deferred.

ReturnsAnother Deferred that fires when the worker is ready to accept another assignment following this one.
API Documentation for AsynQueue, generated by pydoctor at 2022-11-17 13:13:24.