From 6ab00d8ef10ba3804b1f031fd90e5ff1f0adf88a Mon Sep 17 00:00:00 2001
From: Affaan Mustafa <affaan@dcube.ai>
Date: Mon, 11 May 2026 17:15:24 -0400
Subject: [PATCH] fix: route backlog work from lead working dirs

---
 ecc2/src/session/manager.rs | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/ecc2/src/session/manager.rs b/ecc2/src/session/manager.rs
index 7be6f259..ca061aae 100644
--- a/ecc2/src/session/manager.rs
+++ b/ecc2/src/session/manager.rs
@@ -908,11 +908,10 @@ pub async fn drain_inbox(
     use_worktree: bool,
     limit: usize,
 ) -> Result<Vec<InboxDrainOutcome>> {
-    let repo_root =
-        std::env::current_dir().context("Failed to resolve current working directory")?;
     let runner_program =
         std::env::current_exe().context("Failed to resolve ECC executable path")?;
     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 mut outcomes = Vec::new();
 
@@ -1057,11 +1056,10 @@ pub async fn rebalance_team_backlog(
     use_worktree: bool,
     limit: usize,
 ) -> Result<Vec<RebalanceOutcome>> {
-    let repo_root =
-        std::env::current_dir().context("Failed to resolve current working directory")?;
     let runner_program =
         std::env::current_exe().context("Failed to resolve ECC executable path")?;
     let lead = resolve_session(db, lead_id)?;
+    let repo_root = lead.working_dir.clone();
     let mut outcomes = Vec::new();
 
     if limit == 0 {