async def _connect(self) -> None:
        """Establish database connection with timeout and error handling."""
        if not self.conn:
            try:
                self.conn = await aiosqlite.connect(
                    database=self.config["database"],
                    timeout=10.0,
                )
            except aiosqlite.Error as e:
                raise ValueError(f"Database connection failed: {str(e)}") from e
Establish database connection with timeout and error handling.
backend/airweave/platform/sources/sqlite.py