feat(workspace-star): starred workspace priority for concurrency limiting

1 files changed, 5 insertions, 0 deletions

diff --git a/packages/session-orchestrator/src/orchestrator.ts b/packages/session-orchestrator/src/orchestrator.ts
index 5c36922..4c6a673 100644
--- a/packages/session-orchestrator/src/orchestrator.ts
+++ b/packages/session-orchestrator/src/orchestrator.ts
@@ -727,6 +727,7 @@ export function createSessionOrchestrator(
             provider,
             limiter,
             conversationId,
+            workspaceId,
             promptStartedAt,
             () => emitStatus("queued"),
             () => emitStatus("active"),
@@ -1166,10 +1167,12 @@ export function createWarmService(
       // Wrap with concurrency limiting (same as the main turn path).
       const warmLimiter = deps.resolveConcurrencyLimiter?.();
       if (warmLimiter !== undefined) {
+        const warmWorkspaceId = await deps.conversationStore.getWorkspaceId(conversationId);
         provider = wrapProviderWithConcurrency(
           provider,
           warmLimiter,
           conversationId,
+          warmWorkspaceId,
           deps.now?.() ?? Date.now(),
         );
       }
@@ -1323,10 +1326,12 @@ export function createCompactionService(
       // Wrap with concurrency limiting (same as the main turn path).
       const compactionLimiter = deps.resolveConcurrencyLimiter?.();
       if (compactionLimiter !== undefined) {
+        const compactionWorkspaceId = await deps.conversationStore.getWorkspaceId(conversationId);
         provider = wrapProviderWithConcurrency(
           provider,
           compactionLimiter,
           conversationId,
+          compactionWorkspaceId,
           deps.now?.() ?? Date.now(),
         );
       }