Function _create_cli_engine

opc/cli/app.py:439–450

(config, project: str | None)

        return queued if self._mode == "catch_up" else 1

    async def _drain_loop(self) -> None:
        try:
            while self._line_queue:
                now = time.monotonic()
                count = self._drain_count(now)
                for _ in range(min(count, len(self._line_queue))):
                    line = self._line_queue.popleft()
                    self.console.print(line.text, markup=False)
                    self.has_streamed_content = True
                await self._render_status()
                await asyncio.sleep(0.05)
        finally:
            self._drain_task = None

    async def _render_status(self, *, force: bool = False) -> None: