Datastructures - celery.datastructures¶

celery.datastructures

class celery.datastructures.PositionQueue(length)¶

A positional queue with filled/unfilled slots.

class UnfilledPosition(position)¶

Describes an unfilled slot.

PositionQueue.filled¶

Returns the filled slots as a list.

PositionQueue.full()¶

Returns True if all the positions has been filled.

class celery.datastructures.TaskProcessQueue(limit, logger=None, done_msg=None)¶

Queue of running child processes, which starts waiting for the processes to finish when the queue limit is reached.