Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.prefect.io/llms.txt

Use this file to discover all available pages before exploring further.

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