faust.transport.conductor
The conductor delegates messages from the consumer to the streams.
-
class
faust.transport.conductor.ConductorCompiler[source]
Compile a function to handle the messages for a topic+partition.
-
build(conductor: faust.transport.conductor.Conductor, tp: faust.types.tuples.TP, channels: MutableSet[faust.transport.conductor._Topic]) → Callable[faust.types.tuples.Message, Awaitable][source]
Generate closure used to deliver messages.
- Return type
Callable[[Message], Awaitable[+T_co]]
-
class
faust.transport.conductor.Conductor(app: faust.types.app.AppT, **kwargs: Any) → None[source]
Manages the channels that subscribe to topics.
-
logger = <Logger faust.transport.conductor (WARNING)>
-
async
commit(topics: AbstractSet[Union[str, faust.types.tuples.TP]]) → bool[source]
Commit offsets in topics.
- Return type
bool
-
acks_enabled_for(topic: str) → bool[source]
Return True if acks are enabled for topic by name.
- Return type
bool
-
async
wait_for_subscriptions() → None[source]
Wait for consumer to be subscribed.
- Return type
None
-
async
maybe_wait_for_subscriptions() → None[source]
- Return type
None
-
async
on_partitions_assigned(assigned: Set[faust.types.tuples.TP]) → None[source]
Call when cluster is rebalancing and partitions are assigned.
- Return type
None
-
async
on_client_only_start() → None[source]
- Return type
None
-
clear() → None[source]
Clear all subscriptions.
- Return type
None
-
add(topic: Any) → None[source]
Register topic to be subscribed.
- Return type
None
-
discard(topic: Any) → None[source]
Unregister topic from conductor.
- Return type
None
-
property
label
Return label for use in logs.
:rtype: str
-
property
shortlabel
Return short label for use in logs.
:rtype: str
