@@ -15,14 +15,14 @@ const MAX_RESULT_CHARS_PER_ITEM = 6_000;
|
15 | 15 | const MAX_METADATA_CHARS = 500; |
16 | 16 | |
17 | 17 | /** Pending subagent completion selected for requester-session steering. */ |
18 | | -export type AgentSteeringQueueItem = { |
| 18 | +type AgentSteeringQueueItem = { |
19 | 19 | runId: string; |
20 | 20 | entry: SubagentRunRecord; |
21 | 21 | payload: PendingFinalDeliveryPayload; |
22 | 22 | }; |
23 | 23 | |
24 | 24 | /** A batch of leased subagent completions plus the prompt to inject upstream. */ |
25 | | -export type LeasedAgentSteeringBatch = { |
| 25 | +type LeasedAgentSteeringBatch = { |
26 | 26 | runIds: string[]; |
27 | 27 | prompt: string; |
28 | 28 | }; |
@@ -170,9 +170,6 @@ function selectPromptBoundedItems(
|
170 | 170 | return selected; |
171 | 171 | } |
172 | 172 | |
173 | | -/** |
174 | | - * Lease pending steering items and mark them in-progress before prompt injection. |
175 | | - */ |
176 | 173 | /** Leases pending steering items and returns the prompt to prepend to the requester turn. */ |
177 | 174 | export function leasePendingAgentSteeringItemsFromSubagentRuns(params: { |
178 | 175 | runs: Map<string, SubagentRunRecord>; |
@@ -210,7 +207,6 @@ export function leasePendingAgentSteeringItemsFromSubagentRuns(params: {
|
210 | 207 | }; |
211 | 208 | } |
212 | 209 | |
213 | | -/** Acknowledge successfully injected leased steering items. */ |
214 | 210 | /** Marks leased steering items delivered after successful requester injection. */ |
215 | 211 | export function ackLeasedAgentSteeringItemsFromSubagentRuns(params: { |
216 | 212 | runs: Map<string, SubagentRunRecord>; |
@@ -240,7 +236,6 @@ export function ackLeasedAgentSteeringItemsFromSubagentRuns(params: {
|
240 | 236 | return updated; |
241 | 237 | } |
242 | 238 | |
243 | | -/** Release leased steering items after a failed requester turn or injection path. */ |
244 | 239 | /** Releases leased steering items when requester injection fails or is abandoned. */ |
245 | 240 | export function releaseLeasedAgentSteeringItemsFromSubagentRuns(params: { |
246 | 241 | runs: Map<string, SubagentRunRecord>; |
|