diff --git a/.agents/skills/lib_py/delegation/engine.py b/.agents/skills/lib_py/delegation/engine.py
index 1f7fb92..9920701 100644
--- a/.agents/skills/lib_py/delegation/engine.py
+++ b/.agents/skills/lib_py/delegation/engine.py
@@ -399,6 +399,6 @@ def _flush(notifications, registry_dir) -> None:
                     "reason": note.get("reason"),
                     "by": note.get("by"),
                     "timestamp": note.get("timestamp"),
-                })
+                }, logs_dir=logs_dir)
         except Exception as exc:  # pragma: no cover - best effort
             logger.warning("audit mirror failed for %s: %s", job_id, exc)
diff --git a/.agents/skills/lib_py/delegation/registry.py b/.agents/skills/lib_py/delegation/registry.py
index 9a86297..9dff5d8 100755
--- a/.agents/skills/lib_py/delegation/registry.py
+++ b/.agents/skills/lib_py/delegation/registry.py
@@ -241,7 +241,7 @@ def _pick_pending_legacy(agent_session: str, registry_dir: str = DEFAULT_REGISTR
         "to": "running",
         "by": agent_session,
         "timestamp": updated_at,
-    })
+    }, logs_dir=logs_dir)
     return job_id