`prefect.server.logs.messaging`

Log messaging for streaming logs through the messaging system.

Functions

`create_log_publisher`

create_log_publisher() -> AsyncGenerator[messaging.Publisher, None]

Creates a publisher for sending logs to the messaging system. Returns:

A messaging publisher configured for the “logs” topic

`publish_logs`

publish_logs(logs: list[Log]) -> None

Publishes logs to the messaging system. Args:

logs: The logs to publish

exceptions stream

⌘I