Method close

src/agents/memory/sqlite_session.py:344–362

Close the database connection.

(self)

        await asyncio.to_thread(_clear_session_sync)

    def close(self) -> None:
        """Close the database connection."""
        with self._lock:
            if self._closed:
                return

            self._closed = True
            if self._is_memory_db:
                if hasattr(self, "_shared_connection"):
                    self._shared_connection.close()
            else:
                with self._connections_lock:
                    connections = list(self._connections)
                    self._connections.clear()
                for connection in connections:
                    connection.close()
            if self._lock_path is not None and not self._lock_released:
                self._release_file_lock(self._lock_path)
                self._lock_released = True