elias/everything-claude-code
1
0
Fork 0
mirror of https://github.com/affaan-m/everything-claude-code.git synced 2026-05-14 02:10:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: route backlog work from lead working dirs

Browse Source
This commit is contained in:
Affaan Mustafa 2026-05-11 17:15:24 -04:00 committed by Affaan Mustafa
parent c45aeee57f
commit 6ab00d8ef1
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ecc2/src/session/manager.rs
View File

@ -908,11 +908,10 @@ pub async fn drain_inbox(
use_worktree: bool, use_worktree: bool,
limit: usize, limit: usize,
) -> Result<Vec<InboxDrainOutcome>> { ) -> Result<Vec<InboxDrainOutcome>> {
let repo_root =
std::env::current_dir().context("Failed to resolve current working directory")?;
let runner_program = let runner_program =
std::env::current_exe().context("Failed to resolve ECC executable path")?; std::env::current_exe().context("Failed to resolve ECC executable path")?;
let lead = resolve_session(db, lead_id)?; let lead = resolve_session(db, lead_id)?;
let repo_root = lead.working_dir.clone();
let messages = db.unread_task_handoffs_for_session(&lead.id, limit)?; let messages = db.unread_task_handoffs_for_session(&lead.id, limit)?;
let mut outcomes = Vec::new(); let mut outcomes = Vec::new();
@ -1057,11 +1056,10 @@ pub async fn rebalance_team_backlog(
use_worktree: bool, use_worktree: bool,
limit: usize, limit: usize,
) -> Result<Vec<RebalanceOutcome>> { ) -> Result<Vec<RebalanceOutcome>> {
let repo_root =
std::env::current_dir().context("Failed to resolve current working directory")?;
let runner_program = let runner_program =
std::env::current_exe().context("Failed to resolve ECC executable path")?; std::env::current_exe().context("Failed to resolve ECC executable path")?;
let lead = resolve_session(db, lead_id)?; let lead = resolve_session(db, lead_id)?;
let repo_root = lead.working_dir.clone();
let mut outcomes = Vec::new(); let mut outcomes = Vec::new();
if limit == 0 { if limit == 0 {