INNER CODE UNIT · Python

_on_stream_config_changed

yihong1120/Construction-Hazard-Detection · main.py:133

    def _on_stream_config_changed(
        self,
        _connection: object,
        _pid: int,
        _channel: str,
        _payload: str,
    ) -> None:
        """Schedule a reload when PostgreSQL signals a config change."""
        self._config_reload_requested = True
        if self._config_reload_task is None or self._config_reload_task.done():
            reload_task = asyncio.create_task(
                self._reload_configurations_from_notification(),
            )
            reload_task.add_done_callback(
                self._log_config_reload_failure,
            )
            self._config_reload_task = reload_task

View source record →