diff --git a/src/core/task/Task.ts b/src/core/task/Task.ts index cb7576befd..01ea935d82 100644 --- a/src/core/task/Task.ts +++ b/src/core/task/Task.ts @@ -2679,6 +2679,7 @@ export class Task extends EventEmitter implements TaskLike { const sendRateLimitUpdate = async (payload: RateLimitRetryPayload, isPartial: boolean): Promise => { await this.say("api_req_retry_delayed", undefined, undefined, isPartial, undefined, undefined, { + isNonInteractive: true, metadata: { rateLimitRetry: payload }, }) } @@ -2988,7 +2989,7 @@ export class Task extends EventEmitter implements TaskLike { `[Task#attemptApiRequest] task ${this.taskId}.${this.instanceId} aborted during retry`, ) } - + // Delegate generator output from the recursive call with // incremented retry count. yield* this.attemptApiRequest(retryAttempt + 1) @@ -3086,11 +3087,9 @@ export class Task extends EventEmitter implements TaskLike { })() // Helper to send rate limit updates with structured metadata - const sendRateLimitUpdate = async ( - payload: RateLimitRetryPayload, - isPartial: boolean, - ): Promise => { + const sendRateLimitUpdate = async (payload: RateLimitRetryPayload, isPartial: boolean): Promise => { await this.say("api_req_retry_delayed", undefined, undefined, isPartial, undefined, undefined, { + isNonInteractive: true, metadata: { rateLimitRetry: payload }, }) }