faust.transport.conductor

The conductor delegates messages from the consumer to the streams.

class faust.transport.conductor.ConductorCompiler

build(conductor: faust.transport.conductor.Conductor, tp: faust.types.tuples.TP, channels: MutableSet[faust.transport.conductor.Topic]) → Callable[faust.types.tuples.Message, Awaitable]

Return type:Callable[[Message], Awaitable[+T_co]]

class faust.transport.conductor.Conductor(app: faust.types.app.AppT, **kwargs) → None

Manages the channels that subscribe to topics.

• Consumes messages from topic using a single consumer.
• Forwards messages to all channels subscribing to a topic.

logger = <Logger faust.transport.conductor (WARNING)>

acks_enabled_for(topic: str) → bool

Return type:bool

clear() → None

This is slow (creates N new iterators!) but effective.

Return type:None

coroutine commit(self, topics: AbstractSet[Union[str, faust.types.tuples.TP]]) → bool

Return type:bool

coroutine on_partitions_assigned(self, assigned: Set[faust.types.tuples.TP]) → None

Return type:None

coroutine on_partitions_revoked(self, revoked: Set[faust.types.tuples.TP]) → None

Return type:None

coroutine wait_for_subscriptions(self) → None

Return type:None

add(topic: Any) → None

Add an element.

Return type:None

discard(topic: Any) → None

Remove an element. Do not raise an exception if absent.

Return type:None

label

Label used for graphs. :rtype: str

shortlabel

Label used for logging. :rtype: str