This document describes the current stable version of Kombu (5.3). For development docs, go here.

Consumer Scheduling - kombu.utils.scheduling

Scheduling Utilities.

class kombu.utils.scheduling.FairCycle(fun, resources, predicate=<class 'Exception'>)[source]

Cycle between resources.

Consume from a set of resources, where each resource gets an equal chance to be consumed from.

Arguments:

fun (Callable): Callback to call. resources (Sequence[Any]): List of resources. predicate (type): Exception predicate.

close()[source]

Close cycle.

get(callback, **kwargs)[source]

Get from next resource.

class kombu.utils.scheduling.priority_cycle(it=None)[source]

Cycle that repeats items in order.

rotate(last_used)[source]

Unused in this implementation.

class kombu.utils.scheduling.round_robin_cycle(it=None)[source]

Iterator that cycles between items in round-robin.

consume(n)[source]

Consume n items.

rotate(last_used)[source]

Move most recently used item to end of list.

update(it)[source]

Update items from iterable.

class kombu.utils.scheduling.sorted_cycle(it=None)[source]

Cycle in sorted order.

consume(n)[source]

Consume n items.