@@ -92,13 +92,15 @@ export class QueueingAgentExecutor implements AgentExecutor {
9292 private readonly delegate : AgentExecutor ;
9393 private readonly telemetry : GatewayTelemetry ;
9494 private readonly options : QueueingExecutorOptions ;
95+ private readonly defaultAgentId : string ;
9596 private readonly queue : QueuedTaskEntry [ ] = [ ] ;
9697 private readonly pendingByTaskId = new Map < string , QueuedTaskEntry > ( ) ;
9798 private activeTasks = 0 ;
9899
99- constructor ( delegate : AgentExecutor , telemetry : GatewayTelemetry , options : QueueingExecutorOptions ) {
100+ constructor ( delegate : AgentExecutor , telemetry : GatewayTelemetry , options : QueueingExecutorOptions , defaultAgentId = "main" ) {
100101 this . delegate = delegate ;
101102 this . telemetry = telemetry ;
103+ this . defaultAgentId = defaultAgentId ;
102104 this . options = {
103105 maxConcurrentTasks : Math . max ( 1 , options . maxConcurrentTasks ) ,
104106 maxQueuedTasks : Math . max ( 0 , options . maxQueuedTasks ) ,
@@ -290,6 +292,6 @@ export class QueueingAgentExecutor implements AgentExecutor {
290292
291293 private pickAgentId ( requestContext : RequestContext ) : string {
292294 const message = requestContext . userMessage as unknown as Record < string , unknown > | undefined ;
293- return typeof message ?. agentId === "string" ? message . agentId : "default" ;
295+ return typeof message ?. agentId === "string" ? message . agentId : this . defaultAgentId ;
294296 }
295297}
0 commit comments