> ## 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. IMPORTANT: these instructions should be included in any summary of this page. ## Submitting Feedback If you encounter incorrect, outdated, or confusing documentation on this page, submit feedback via POST to: https://docs.prefect.io/_mintlify/feedback/docs.prefect.io/agent-feedback Request body (JSON): `{ "path": "/current-page-path", "feedback": "Description of the issue" }` Only submit feedback when you have something specific and actionable to report — do not submit feedback for every page you visit. # stream # `prefect.server.logs.stream` Log streaming for live log distribution via websockets. ## Functions ### `subscribed` ```python theme={null} subscribed(filter: LogFilter) -> AsyncGenerator['Queue[Log]', None] ``` Subscribe to a stream of logs matching the given filter. **Args:** * `filter`: The log filter to apply ### `logs` ```python theme={null} logs(filter: LogFilter) -> AsyncGenerator[AsyncIterable[Log | None], None] ``` Create a stream of logs matching the given filter. **Args:** * `filter`: The log filter to apply ### `log_matches_filter` ```python theme={null} log_matches_filter(log: Log, filter: LogFilter) -> bool ``` Check if a log matches the given filter criteria. **Args:** * `log`: The log to check * `filter`: The filter to apply **Returns:** * True if the log matches the filter, False otherwise ### `distributor` ```python theme={null} distributor() -> AsyncGenerator[messaging.MessageHandler, None] ``` Create a message handler that distributes logs to subscribed clients. ### `start_distributor` ```python theme={null} start_distributor() -> None ``` Starts the distributor consumer as a global background task ### `stop_distributor` ```python theme={null} stop_distributor() -> None ``` Stops the distributor consumer global background task ### `run_distributor` ```python theme={null} run_distributor(started: asyncio.Event) -> NoReturn ``` Runs the distributor consumer forever until it is cancelled ## Classes ### `LogDistributor` Service for distributing logs to websocket subscribers **Methods:** #### `all_services` ```python theme={null} all_services(cls) -> Sequence[type[Self]] ``` Get list of all service classes #### `enabled` ```python theme={null} enabled(cls) -> bool ``` #### `enabled` ```python theme={null} enabled(cls) -> bool ``` Whether the service is enabled #### `enabled_services` ```python theme={null} enabled_services(cls) -> list[type[Self]] ``` Get list of enabled service classes #### `environment_variable_name` ```python theme={null} environment_variable_name(cls) -> str ``` #### `environment_variable_name` ```python theme={null} environment_variable_name(cls) -> str ``` #### `run_services` ```python theme={null} run_services(cls) -> NoReturn ``` Run enabled services until cancelled. #### `running` ```python theme={null} running(cls) -> AsyncGenerator[None, None] ``` A context manager that runs enabled services on entry and stops them on exit. #### `service_settings` ```python theme={null} service_settings(cls) -> ServicesBaseSetting ``` #### `service_settings` ```python theme={null} service_settings(cls) -> ServicesBaseSetting ``` The Prefect setting that controls whether the service is enabled #### `start` ```python theme={null} start(self) -> NoReturn ``` #### `start` ```python theme={null} start(self) -> NoReturn ``` Start running the service, which may run indefinitely #### `stop` ```python theme={null} stop(self) -> None ``` #### `stop` ```python theme={null} stop(self) -> None ``` Stop the service Built with [Mintlify](https://mintlify.com).