2026-10-15 13:52:10 +00:00
2 changed files with 2 additions and 2 deletions
@@ -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)
@@ -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