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