Compare commits
1 Commits
sprint/iss
...
fix/674-ga
| Author | SHA1 | Date | |
|---|---|---|---|
| d018c769bb |
@@ -33,6 +33,11 @@ from pathlib import Path
|
||||
from typing import Optional
|
||||
|
||||
|
||||
# ── Gate File Rotation ──────────────────────────────────────────────
|
||||
GATE_FILE_MAX_AGE_DAYS = 7
|
||||
GATE_FILE_MAX_COUNT = 50
|
||||
|
||||
|
||||
# ── SOUL.md Constraints ──────────────────────────────────────────────
|
||||
#
|
||||
# These are the non-negotiable categories from SOUL.md and the
|
||||
@@ -240,6 +245,9 @@ def evaluate_candidate(
|
||||
latest_file = gate_dir / "eval_gate_latest.json"
|
||||
latest_file.write_text(json.dumps(result, indent=2))
|
||||
|
||||
# Rotate old gate files to prevent unbounded growth
|
||||
_rotate_gate_files(gate_dir)
|
||||
|
||||
return result
|
||||
|
||||
|
||||
@@ -249,6 +257,48 @@ def _load_json(path: str | Path) -> dict:
|
||||
return json.loads(Path(path).read_text())
|
||||
|
||||
|
||||
def _rotate_gate_files(gate_dir: Path) -> None:
|
||||
"""Clean up old gate files to prevent unbounded directory growth.
|
||||
|
||||
- Deletes files older than GATE_FILE_MAX_AGE_DAYS
|
||||
- Caps total count at GATE_FILE_MAX_COUNT (oldest first)
|
||||
- Always preserves eval_gate_latest.json
|
||||
"""
|
||||
if not gate_dir.exists():
|
||||
return
|
||||
|
||||
latest_name = "eval_gate_latest.json"
|
||||
cutoff = datetime.now(timezone.utc).timestamp() - (GATE_FILE_MAX_AGE_DAYS * 86400)
|
||||
|
||||
gate_files = []
|
||||
for f in gate_dir.iterdir():
|
||||
if f.name == latest_name or not f.name.startswith("eval_gate_") or f.suffix != ".json":
|
||||
continue
|
||||
try:
|
||||
mtime = f.stat().st_mtime
|
||||
except OSError:
|
||||
continue
|
||||
gate_files.append((mtime, f))
|
||||
|
||||
# Sort oldest first
|
||||
gate_files.sort(key=lambda x: x[0])
|
||||
|
||||
deleted = 0
|
||||
for mtime, f in gate_files:
|
||||
should_delete = False
|
||||
if mtime < cutoff:
|
||||
should_delete = True
|
||||
elif len(gate_files) - deleted > GATE_FILE_MAX_COUNT:
|
||||
should_delete = True
|
||||
|
||||
if should_delete:
|
||||
try:
|
||||
f.unlink()
|
||||
deleted += 1
|
||||
except OSError:
|
||||
pass
|
||||
|
||||
|
||||
def _find_category_score(
|
||||
sessions: dict[str, dict],
|
||||
category: str,
|
||||
|
||||
@@ -196,37 +196,7 @@
|
||||
"paused_reason": null,
|
||||
"skills": [],
|
||||
"skill": null
|
||||
},
|
||||
{
|
||||
"id": "tmux-supervisor-513",
|
||||
"name": "Autonomous Cron Supervisor",
|
||||
"prompt": "Load the tmux-supervisor skill and execute the monitoring protocol.\n\nCheck both `dev` and `timmy` tmux sessions for idle panes. Only send Telegram notifications on actionable events (idle, overflow, failure). Be silent when all agents are working.\n\nSteps:\n1. List all tmux sessions (skip 'Alexander')\n2. For each session, list windows and panes\n3. Capture each pane and classify state (idle vs active)\n4. For idle panes: read context, craft context-aware prompt\n5. Send /queue prompts to idle panes\n6. Verify prompts landed\n7. Only notify via Telegram if:\n - A pane was prompted (idle detected)\n - A pane shows context overflow (>80%)\n - A pane is stuck or crashed\n8. If all panes are active: respond with [SILENT]",
|
||||
"schedule": {
|
||||
"kind": "interval",
|
||||
"minutes": 7,
|
||||
"display": "every 7m"
|
||||
},
|
||||
"schedule_display": "every 7m",
|
||||
"repeat": {
|
||||
"times": null,
|
||||
"completed": 0
|
||||
},
|
||||
"enabled": true,
|
||||
"created_at": "2026-04-15T03:00:00.000000+00:00",
|
||||
"next_run_at": null,
|
||||
"last_run_at": null,
|
||||
"last_status": null,
|
||||
"last_error": null,
|
||||
"deliver": "telegram",
|
||||
"origin": null,
|
||||
"state": "scheduled",
|
||||
"paused_at": null,
|
||||
"paused_reason": null,
|
||||
"skills": [
|
||||
"tmux-supervisor"
|
||||
],
|
||||
"skill": "tmux-supervisor"
|
||||
}
|
||||
],
|
||||
"updated_at": "2026-04-13T02:00:00+00:00"
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user