Skip to content

Commit d214e70

Browse files
committed
fix: rem duplicate chek
1 parent b32e884 commit d214e70

1 file changed

Lines changed: 0 additions & 32 deletions

File tree

packages/core/src/traffic/traffic-controller.ts

Lines changed: 0 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -1296,38 +1296,6 @@ export class TrafficController {
12961296
return { action: "continue", wakeUpAt };
12971297
}
12981298

1299-
/* -------------------- Final queue timeout -------------------- */
1300-
1301-
if (queueTimeoutExpired) {
1302-
const timeoutError = this.createQueueTimeoutError(next, now);
1303-
1304-
this.attachTrafficMetadata(
1305-
timeoutError,
1306-
this.buildTrafficResponseMetadata(
1307-
next,
1308-
timeoutError.rateLimitKey ?? this.buildRateLimitKey(next.request.metadata),
1309-
now,
1310-
timeoutError,
1311-
),
1312-
);
1313-
1314-
this.controllerLogger.warn("Queue wait timed out before dispatch", {
1315-
tenantId: next.tenantId,
1316-
waitedMs: timeoutError.waitedMs,
1317-
maxQueueWaitMs: timeoutError.maxQueueWaitMs,
1318-
deadlineAt: timeoutError.deadlineAt,
1319-
provider: next.request.metadata?.provider,
1320-
model: next.request.metadata?.model,
1321-
rateLimitKey: timeoutError.rateLimitKey,
1322-
});
1323-
1324-
queue.shift();
1325-
this.cleanupTenantQueue(priority, tenantId, queue);
1326-
next.reject(timeoutError);
1327-
1328-
return { action: "skip", wakeUpAt };
1329-
}
1330-
13311299
/* -------------------- Dispatch -------------------- */
13321300

13331301
this.startRequest(next, queue, tenantId);

0 commit comments

Comments
 (0)