INNER CODE UNIT · Python

_restart_stream_process

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

    async def _restart_stream_process(
        self,
        stream_key: str,
        proc_info: dict[str, Any],
        cfg: StreamConfig,
    ) -> None:
        """Restart one stream process and refresh its process metadata."""
        reason = self._restart_reason(proc_info, cfg)
        self.logger.info(
            'Restart stream %s (%s)',
            self._stream_log_label(cfg),
            reason,
        )
        self.stop_process(proc_info['process'])
        await self._delete_stream_redis_keys(proc_info['cfg'])
        new_proc = self.start_process(cfg)
        self.running_processes[stream_key] = {
            'process': new_proc,

View source record →