This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.1.
Consumer Scheduling - kombu.utils.scheduling
¶
Scheduling Utilities.
-
class
kombu.utils.scheduling.
FairCycle
(fun, resources, predicate=<type 'exceptions.Exception'>)[source]¶ Cycle between resources.
Consume from a set of resources, where each resource gets an equal chance to be consumed from.
Parameters: - fun (Callable) – Callback to call.
- resources (Sequence[Any]) – List of resources.
- predicate (type) – Exception predicate.