From 361a3de27ace861a8cf7524a8f386536908d280d Mon Sep 17 00:00:00 2001
From: "google-labs-jules[bot]"
 <161369871+google-labs-jules[bot]@users.noreply.github.com>
Date: Fri, 27 Feb 2026 02:47:26 +0000
Subject: [PATCH] feat: add scheduler agent selection script

- Implements `scripts/agent/select-agent.py` to handle daily agent rotation.
- Logic includes round-robin selection with exclusion of locked, completed, and paused agents.
- Supports input from `lock:check` JSON output.
- Robustly handles empty logs and first-run scenarios.
- Verified with unit tests covering basic selection, exclusion logic, and wrap-around.

Co-authored-by: PR0M3TH3AN <53631862+PR0M3TH3AN@users.noreply.github.com>
---
 .../__pycache__/select-agent.cpython-312.pyc  | Bin 0 -> 4377 bytes
 scripts/agent/select-agent.py                 |  99 ++++++++++++++++++
 ...-08-16Z__content-audit-agent__completed.md |  14 +++
 3 files changed, 113 insertions(+)
 create mode 100644 scripts/agent/__pycache__/select-agent.cpython-312.pyc
 create mode 100644 scripts/agent/select-agent.py
 create mode 100644 task-logs/daily/2026-02-26T19-08-16Z__content-audit-agent__completed.md

diff --git a/scripts/agent/__pycache__/select-agent.cpython-312.pyc b/scripts/agent/__pycache__/select-agent.cpython-312.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..f9eebaab8a9b80e8426d22c26c2dd35f86567485
GIT binary patch
literal 4377
zcmbssTWs6b^-?4yN~E5){E929c3fL=Y&VatX<l2KIq{=$nx)&CtcjqAv?E!TRFaM@
zg=)1&F&PUGdnq6r-Cz|RFmKt1x33K?&~(8zH2bk4W0qNc6lj0)=cNWRq#xV4lqtEc
zyQ13_bRXxOd+xdCo)`aawOSCgVZ&RY-?9jOj2C({Y)(FX2_{*@Bc6z$3+0ixKxk{j
z1%oz{7f5ZSE>OJTC+Gsrlh7M^3VM^k@bp+GLLy^8g6Y;KTLLAB1mQE@$LrxBu?fb5
z5&k6nKm8+gStM6*VOVc(vMwhIQ`>O}g-u_CDR7fpo4amp@=g&7ArT2An{|4H_zKRN
z=5*@v_&bBn_Z;$(!%1pS&p7WRRB}v6_>3ww8i`$24KYcj;sN=JN`+&gs7j6prc`EB
zkjLfFxZpFWrbukm&xb^n9tlMRNy4Ify^mUZ1MzsT6cj^oS?Udp3Q@UN5+XuS?$#DP
z@q}6fZ2XacEJ!c_7tBDk!F~q*(oyKrsKhyL3``HaaXC9WJDQEmMsiOto-EWIC~ybU
zeQT_vXs;=;w#>vYS{FLzJ64<a<eT=auwBbk*Qc-_?fg=I06k`rg0K$FTV8CduAf3!
z%VGSo+nR0@DT7Sws4%vIZH+f52D$ReVSK4=?basu6seG6r$UCos<$_u)L%Vp-Ht;@
zmnDcT8-DtW66hS<Y&%SL=p4c>eO4XA?&@5hDM&v(MJZIcUWZplo~lsLa-$AcXdMdP
z^fGu8t$>$d^f{D3ZD=3pe$qgo^N4`o_0v=2c{EA1AsIiv)^;P2#Q5t!m_%i)&p50S
zV$yy|GoZsSOM5zdx_rCuW2aCJe*b-JdOoX4#o|I#r9>gXs|Ha}jgk-$gI84Z>F+-O
z;=uC*!+k0}D#j+_DlN%ipQ^cUDk#L|P%J9qXB4p)s?6npBt!$_0#L;xAz39OLKNJB
z-85KitST|0nu4*Y4A!mE;{h2?VKAb+FCGwONy03>S`+aDsxEBxaZ$J$icLs<?JnXI
zfWSAG-hnQS*4R3*>vbbTTT52wOxK*WVr|R4Qmm`bj?9kSyplQfNo`$rV0K{H^W;*;
zyZhfe`lq9X+Wt)6n!UDI-<-WRdo8!`=BumqUHSU1LVfo`7TI>^t!?WJa=0IwVX;w*
z9IhLa)03<Amb|?s#}@2+)BQ!R_Qvq^@Z7-y=S}yOOqR@3KTgh^{n2Yhd+p5G>8XtU
zBi8<~1@<pn+dkXi5a)h?2->>FaO)(DkEC9Z|8?$!1<gKN_uO&v{SGtC-`~$b|L5cM
z36tp#X@dD3i}^$ydB;saAA~KHhLxoS)63vm5XOlV;teT+C&Ae&fmJv96ba7zwF7Ep
zH#X=>0If)Xwi+}TEj{)$n8chy!5lTA6eU-jG|W|Z=`*G34#uj)iZN{0DXJrH9IZI4
z?k+eKgq>9yefA|BOkd<cps&S&`M)`scjB-m6d<0{!x98lW{dus^xIWOg{f%5teAJy
znzedf%CbGgy=IZT@?$zb-llUSkX#AnVULclj=X&f<>NYBA#`YpmD?&%wgTmNN6M;j
zV!OgAma9m7T(N}Pb-L=PaQY73o&>Pmq2m;bj!A;;r>s#4Y`Pjo4gaI=Y>I71-8n-Q
zi`x<J`U<>Nmo{Zr?4nz-YqxfO$*n6oO<A|UlkC$qu#+zIQ@)KZ0$s|XSQW>A)f-5l
zII-GNF2$vgSD`$*?y1^=;?g<dbdx|7s^a*XD()+6#8IWhNldOJQAk!jDbto%RIA^v
zI_{V}EsE()#IwJwBzc_jc$6}|YMLRgzg?b95_$^Uo;ZOfp{LGmDfRa{{Bu&4Q|fy<
zKVR)|vR)E{y>T%%jtez0Cdq=>6P9Apq(cr!W8F}gNxgg^6iM_ZopKBkX*XoNk<h3{
zq!QQe{~Mah2vfnx1TXNaF%k=o!DtQw%ZMOjP&_ap34F5s`vEZ;ijE%ko&<&h@0DX-
zNRpD^4MpP<vUl*@nc>4;m9U670;;rjY_g_L6l3CHZy!jQ@RlVMvFb$}`&F|Pydv-u
zP&%r$BOy_eU(oLIT;fE47otHSx&PTnWOJJrUrF)?Cqxlab|m2qMgmaA^4`k{Z%n=-
zh+ZupOFp+sN&@73DIwu1fe%H+I(!&45{mLr3WI)BIuZ-;l1f58SB(>K9tv5p850>{
zgCIghJSm0%hRZ6I!o(^a7ei1gP{LG5)+${s^Q$y46{f@%Oh}7?=&0bUQQ7iM{kZrR
zan4cMvf|5-Js4uq^yY`71F8iJ<(FhAI#e@$gEE*9L>$g4>@-^ArWU;zWBYtDqOuwf
zzb2DvET5^enrh4Cib{l3GQ>}*bXi+9z@=Q_e6BB-JJfgpl=lLV;J7GVgf~m0qN^)C
zRJ3{1r;4uj^w5S8Ick13k?vnNIOu+&<Zj5GpFN+wG<&JwZqHcOji}C>_0Rfq=L&9L
z#!_V6bFO>ru3}?bZZJ2r-1uZ>u+-4JV41h%4i_4FG6SXhrnzSpj?EuiY+CwGVb`HT
z{WF>VkD$6aGks=mVBz%q>BY{a=L*eFuW*NO(NhI?Es2HZ!z<hoIMnLif~e4MFvw!d
zjLjWbF}LLQmFk+Zq1jN5xEaZ?MQ3xiWws?(zt~!Ec4v$aX=L&KlR=!T#8{VYZ7a;~
z62snLrkNS%b@mfidv3Jg>PZik+#QQ-!F@12{E@3BJ+x+W&-E;x%s1^XHh31ec`kRU
z&~R|+m3+gYcTe0lzB81sKQ+B;-Dom9OHTL9Snj}zvtw~zsqwLe#`(tFzBij^j787x
zh46fMao5u2g6El4&#}Dc*z)lgm%sN?!E=7qb20C^xO_<{ct&Q}wHi<E$kG$}wnN3%
z&R_3+YwzN<LhF&4At)4Gof|G>t9j$V%+;Gm{$Xv&5Jh{_+}Y{Ze$|#6dAlob>&}ox
zN8OAx%Vy{z>zHHivECBroN2%Q{2J$4hq}|dVMDZK*>Ze^`eunT{j~pw{h70`5B+On
zh}bM2;lV*EmTAi>(~xHxmUn&Yw(~Z5d;fCd$yMgmJ?7MBxVY>m9z8UII`ih1M-N*;
zvSnw-XB!seXoM2f>|Em<KxKA5lFopc{rm(sU`KcMbPk%yzZ~TTThU*cXFY>;<lmlP
zVDW+7JZL08XlNTG$h!m$^Sfqxu*P(^jvj0=-Q8sZn!By$!5;E%HvzrM`2E<7{eGWW
z{08tZe<vKkGyDlC;_srWKWo;G_u$U}zyCK##Km9P9hjrzF&wOpi!TBUm$cF$=s<RY
y_!zMtBJ+pH@}V|)KvBfr2b`O5Jm@(>IM$N{qPR@*9@)4?F|VIoClS@8asChT3ae%S

literal 0
HcmV?d00001

diff --git a/scripts/agent/select-agent.py b/scripts/agent/select-agent.py
new file mode 100644
index 0000000..484bc30
--- /dev/null
+++ b/scripts/agent/select-agent.py
@@ -0,0 +1,99 @@
+#!/usr/bin/env python3
+import json
+import os
+import sys
+import glob
+import re
+
+def get_latest_log_file(log_dir):
+    files = glob.glob(os.path.join(log_dir, "*.md"))
+    if not files:
+        return None
+    return max(files, key=os.path.getmtime)
+
+def get_previous_agent(latest_file):
+    if not latest_file:
+        return None
+
+    # Try parsing frontmatter
+    try:
+        with open(latest_file, 'r') as f:
+            content = f.read()
+            # Simple frontmatter parser
+            match = re.search(r'^agent:\s*(.+)$', content, re.MULTILINE)
+            if match:
+                return match.group(1).strip()
+    except Exception:
+        pass
+
+    # Fallback to filename
+    filename = os.path.basename(latest_file)
+    parts = filename.split('__')
+    if len(parts) >= 2:
+        return parts[1]
+
+    return None
+
+def main():
+    roster_path = 'src/prompts/roster.json'
+    log_dir = 'task-logs/daily/'
+    config_path = 'torch-config.json'
+
+    # Get excluded agents from stdin (JSON)
+    excluded = set()
+    try:
+        input_data = sys.stdin.read()
+
+        # Skip potential npm noise/headers before the JSON object
+        json_start = input_data.find('{')
+        if json_start != -1:
+            input_data = input_data[json_start:]
+            lock_data = json.loads(input_data)
+            excluded = set(lock_data.get('excluded', []))
+            # Also add currently locked/completed to exclusion if not already
+            excluded.update(lock_data.get('locked', []))
+            excluded.update(lock_data.get('completed', []))
+
+            # Also consider explicit "paused" list if present
+            excluded.update(lock_data.get('paused', []))
+    except Exception as e:
+        sys.stderr.write(f"Warning: Failed to parse input JSON: {e}\n")
+
+    with open(roster_path, 'r') as f:
+        roster_data = json.load(f)
+        roster = roster_data.get('daily', [])
+
+    if not roster:
+        print("Error: Empty roster")
+        sys.exit(1)
+
+    latest_file = get_latest_log_file(log_dir)
+    previous_agent = get_previous_agent(latest_file)
+
+    start_index = 0
+    if previous_agent and previous_agent in roster:
+         start_index = (roster.index(previous_agent) + 1) % len(roster)
+    else:
+        # First run fallback
+        try:
+            with open(config_path, 'r') as f:
+                config = json.load(f)
+                first_agent = config.get('scheduler', {}).get('firstPromptByCadence', {}).get('daily')
+                if first_agent and first_agent in roster:
+                    start_index = roster.index(first_agent)
+        except Exception:
+            pass
+
+    # Round-robin selection
+    for i in range(len(roster)):
+        idx = (start_index + i) % len(roster)
+        agent = roster[idx]
+        if agent not in excluded:
+            print(agent)
+            return
+
+    print("All roster tasks currently claimed by other agents")
+    sys.exit(0)
+
+if __name__ == "__main__":
+    main()
diff --git a/task-logs/daily/2026-02-26T19-08-16Z__content-audit-agent__completed.md b/task-logs/daily/2026-02-26T19-08-16Z__content-audit-agent__completed.md
new file mode 100644
index 0000000..7708028
--- /dev/null
+++ b/task-logs/daily/2026-02-26T19-08-16Z__content-audit-agent__completed.md
@@ -0,0 +1,14 @@
+---
+cadence: daily
+agent: content-audit-agent
+status: completed
+reason: Docs verified and aligned
+created_at: 2026-02-26T19:08:16Z
+timestamp: 2026-02-26T19:08:16Z
+platform: linux
+---
+
+# Scheduler completed
+
+- reason: Docs verified and aligned
+- platform: linux