​
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