let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: retry embedding 5xx errors

Browse Source
This commit is contained in:
Peter Steinberger
2026-01-17 22:48:50 +00:00
parent 9ca4c10e59
commit 7d2e510087
4 changed files with 59 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/memory/manager.ts
View File

@@ -733,7 +733,7 @@ export class MemoryIndexManager {
params.progress.report({
completed: params.progress.completed,
total: params.progress.total,
label: "Indexing memory files…",
label: this.batch.enabled ? "Indexing memory files (batch)..." : "Indexing memory files…",
});
}
@@ -784,7 +784,7 @@ export class MemoryIndexManager {
params.progress.report({
completed: params.progress.completed,
total: params.progress.total,
label: "Indexing session files…",
label: this.batch.enabled ? "Indexing session files (batch)..." : "Indexing session files…",
});
}
@@ -1357,7 +1357,7 @@ export class MemoryIndexManager {
return await this.provider.embedBatch(texts);
} catch (err) {
const message = err instanceof Error ? err.message : String(err);
if (!this.isRateLimitError(message) || attempt >= EMBEDDING_RETRY_MAX_ATTEMPTS) {
if (!this.isRetryableEmbeddingError(message) || attempt >= EMBEDDING_RETRY_MAX_ATTEMPTS) {
throw err;
}
const waitMs = Math.min(
@@ -1372,8 +1372,10 @@ export class MemoryIndexManager {
}
}
private isRateLimitError(message: string): boolean {
return /(rate[_ ]limit|too many requests|429|resource has been exhausted)/i.test(message);
private isRetryableEmbeddingError(message: string): boolean {
return /(rate[_ ]limit|too many requests|429|resource has been exhausted|5\d\d|cloudflare)/i.test(
message,
);
}
private async runWithConcurrency<T>(tasks: Array<() => Promise<T>>, limit: number): Promise<T[]> {