bkinnightskytw
/
agent-orchestrator
mirror of https://github.com/ComposioHQ/agent-orchestrator.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

perf(cli): parallelize I/O calls in 'ao session ls' for faster listing

This commit is contained in:
harshitsinghbhandari 2026-03-29 18:28:04 +05:30
parent dd21054f48
commit 124cc33745
1 changed files with 23 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
packages/cli/src/commands/session.ts
View File

@ -51,17 +51,30 @@ export function registerSession(program: Command): void {
continue;
}
for (const s of projectSessions) {
// Get live branch from worktree if available
let branchStr = s.branch || "";
if (s.workspacePath) {
const liveBranch = await git(["branch", "--show-current"], s.workspacePath);
if (liveBranch) branchStr = liveBranch;
}
// Pre-fetch all branches and activities in parallel
const branches = await Promise.all(
projectSessions.map(async (s) => {
if (s.workspacePath) {
return git(["branch", "--show-current"], s.workspacePath).catch(() => null);
}
return null;
}),
);
// Get tmux activity age
const tmuxTarget = s.runtimeHandle?.id ?? s.id;
const activityTs = await getTmuxActivity(tmuxTarget);
const activities = await Promise.all(
projectSessions.map((s) => {
const tmuxTarget = s.runtimeHandle?.id ?? s.id;
return getTmuxActivity(tmuxTarget).catch(() => null);
}),
);
for (let i = 0; i < projectSessions.length; i++) {
const s = projectSessions[i];
const liveBranch = branches[i];
const activityTs = activities[i];
// Priority: live branch from workspace > metadata branch > empty string
let branchStr = (s.workspacePath && liveBranch) ? liveBranch : (s.branch || "");
const age = activityTs ? formatAge(activityTs) : "-";
const parts = [chalk.green(s.id), chalk.dim(`(${age})`)];