From fdfff82f5b149e753577bb963b4d66efd86a5536 Mon Sep 17 00:00:00 2001 From: Wheat Carrier Date: Sat, 11 May 2024 17:01:55 +0800 Subject: [PATCH] . --- src/api/client/message-api/file-uploader.ts | 12 +----------- src/utils/retry.ts | 1 + 2 files changed, 2 insertions(+), 11 deletions(-) diff --git a/src/api/client/message-api/file-uploader.ts b/src/api/client/message-api/file-uploader.ts index bdcffc8..5711f1e 100644 --- a/src/api/client/message-api/file-uploader.ts +++ b/src/api/client/message-api/file-uploader.ts @@ -78,8 +78,7 @@ export abstract class FileUploader { const chunk = await this.read(chunkLength.toJSNumber()); - let retry = 3; - while (retry) { + while (true) { try { const rsp = this.isBig ? await this.client.saveBigFilePart({ @@ -108,15 +107,6 @@ export abstract class FileUploader { throw new FileTooBig(this.fileSize); } } - - Logger.error( - `error encountered in uploading worker ${workerId}: ${err} retries left: ${retry}`, - ); - - retry -= 1; - if (retry === 0) { - throw err; - } } } } diff --git a/src/utils/retry.ts b/src/utils/retry.ts index b56e1db..c8d6f1b 100644 --- a/src/utils/retry.ts +++ b/src/utils/retry.ts @@ -16,6 +16,7 @@ export function retry( const result = await originalMethod.apply(this, args); return result; } catch (error) { + console.error(error); if (i === retries) throw error; const waitTime = Math.pow(2, i) * backoff; Logger.error(