prefect.server.logs.messaging

Log messaging for streaming logs through the messaging system.

Functions

create_log_publisher ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/logs/messaging.py#L22" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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 ^{<a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/logs/messaging.py#L33" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a>}

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

Publishes logs to the messaging system.

Args:

• logs: The logs to publish