zsp/everything-claude-code
1
0
Fork 0
mirror of https://github.com/affaan-m/everything-claude-code.git synced 2026-04-09 02:43:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: tune ecc2 dispatch limits

Browse Source
This commit is contained in:
Affaan Mustafa
2026-04-07 13:20:22 -07:00
parent a7309481f4
commit 098b773c11
2 changed files with 33 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ecc2/src/tui/app.rs
View File

@@ -44,6 +44,8 @@ pub async fn run(db: StateStore, cfg: Config) -> Result<()> {
(_, KeyCode::Char('i')) => dashboard.drain_inbox_selected().await, (_, KeyCode::Char('i')) => dashboard.drain_inbox_selected().await,
(_, KeyCode::Char('g')) => dashboard.auto_dispatch_backlog().await, (_, KeyCode::Char('g')) => dashboard.auto_dispatch_backlog().await,
(_, KeyCode::Char('p')) => dashboard.toggle_auto_dispatch_policy(), (_, KeyCode::Char('p')) => dashboard.toggle_auto_dispatch_policy(),
(_, KeyCode::Char(',')) => dashboard.adjust_auto_dispatch_limit(-1),
(_, KeyCode::Char('.')) => dashboard.adjust_auto_dispatch_limit(1),
(_, KeyCode::Char('s')) => dashboard.stop_selected().await, (_, KeyCode::Char('s')) => dashboard.stop_selected().await,
(_, KeyCode::Char('u')) => dashboard.resume_selected().await, (_, KeyCode::Char('u')) => dashboard.resume_selected().await,
(_, KeyCode::Char('x')) => dashboard.cleanup_selected_worktree().await, (_, KeyCode::Char('x')) => dashboard.cleanup_selected_worktree().await,

35
ecc2/src/tui/dashboard.rs
View File

@@ -400,7 +400,7 @@ impl Dashboard {
fn render_status_bar(&self, frame: &mut Frame, area: Rect) { fn render_status_bar(&self, frame: &mut Frame, area: Rect) {
let text = format!( let text = format!(
" [n]ew session [a]ssign re[b]alance dra[i]n inbox [g]lobal dispatch toggle [p]olicy [s]top [u]resume [x]cleanup [d]elete [r]efresh [Tab] switch pane [j/k] scroll [+/-] resize [{}] layout [?] help [q]uit ", " [n]ew session [a]ssign re[b]alance dra[i]n inbox [g]lobal dispatch toggle [p]olicy [,/.] dispatch limit [s]top [u]resume [x]cleanup [d]elete [r]efresh [Tab] switch pane [j/k] scroll [+/-] resize [{}] layout [?] help [q]uit ",
self.layout_label() self.layout_label()
); );
let text = if let Some(note) = self.operator_note.as_ref() { let text = if let Some(note) = self.operator_note.as_ref() {
@@ -450,6 +450,7 @@ impl Dashboard {
" i Drain unread task handoffs from selected session inbox", " i Drain unread task handoffs from selected session inbox",
" g Auto-dispatch unread handoffs across lead sessions", " g Auto-dispatch unread handoffs across lead sessions",
" p Toggle daemon auto-dispatch policy and persist config", " p Toggle daemon auto-dispatch policy and persist config",
" ,/. Decrease/increase auto-dispatch limit per lead",
" s Stop selected session", " s Stop selected session",
" u Resume selected session", " u Resume selected session",
" x Cleanup selected worktree", " x Cleanup selected worktree",
@@ -932,6 +933,31 @@ impl Dashboard {
} }
} }
pub fn adjust_auto_dispatch_limit(&mut self, delta: isize) {
let next = (self.cfg.auto_dispatch_limit_per_session as isize + delta).clamp(1, 50) as usize;
if next == self.cfg.auto_dispatch_limit_per_session {
self.set_operator_note(format!(
"auto-dispatch limit unchanged at {} handoff(s) per lead",
self.cfg.auto_dispatch_limit_per_session
));
return;
}
let previous = self.cfg.auto_dispatch_limit_per_session;
self.cfg.auto_dispatch_limit_per_session = next;
match self.cfg.save() {
Ok(()) => self.set_operator_note(format!(
"auto-dispatch limit set to {} handoff(s) per lead | saved to {}",
self.cfg.auto_dispatch_limit_per_session,
crate::config::Config::config_path().display()
)),
Err(error) => {
self.cfg.auto_dispatch_limit_per_session = previous;
self.set_operator_note(format!("failed to persist auto-dispatch limit: {error}"));
}
}
}
pub async fn tick(&mut self) { pub async fn tick(&mut self) {
loop { loop {
match self.output_rx.try_recv() { match self.output_rx.try_recv() {
@@ -1300,10 +1326,11 @@ impl Dashboard {
} }
lines.push(format!( lines.push(format!(
"Global handoff backlog {} lead(s) / {} handoff(s) | Auto-dispatch {}", "Global handoff backlog {} lead(s) / {} handoff(s) | Auto-dispatch {} @ {}/lead",
self.global_handoff_backlog_leads, self.global_handoff_backlog_leads,
self.global_handoff_backlog_messages, self.global_handoff_backlog_messages,
if self.cfg.auto_dispatch_unread_handoffs { "on" } else { "off" } if self.cfg.auto_dispatch_unread_handoffs { "on" } else { "off" },
self.cfg.auto_dispatch_limit_per_session
)); ));
if let Some(route_preview) = self.selected_route_preview.as_ref() { if let Some(route_preview) = self.selected_route_preview.as_ref() {
@@ -1901,7 +1928,7 @@ mod tests {
let text = dashboard.selected_session_metrics_text(); let text = dashboard.selected_session_metrics_text();
assert!(text.contains("Team 3/8 | idle 1 | running 1 | pending 1 | failed 0 | stopped 0")); assert!(text.contains("Team 3/8 | idle 1 | running 1 | pending 1 | failed 0 | stopped 0"));
assert!(text.contains("Global handoff backlog 2 lead(s) / 5 handoff(s) | Auto-dispatch off")); assert!(text.contains("Global handoff backlog 2 lead(s) / 5 handoff(s) | Auto-dispatch off @ 5/lead"));
assert!(text.contains("Next route reuse idle worker-1")); assert!(text.contains("Next route reuse idle worker-1"));
} }