fix: ignore BodyTimeoutError (#603)

cnpm · Oct 28, 2023 · cde4f03 · cde4f03
1 parent c3c7b39
commit cde4f03
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/app/core/service/BinarySyncerService.ts b/app/core/service/BinarySyncerService.ts
@@ -146,13 +146,15 @@ export class BinarySyncerService extends AbstractService {
       task.error = err.message;
       logs.push(`[${isoNow()}] ❌ Synced "${binaryName}" fail, ${task.error}, log: ${logUrl}`);
       logs.push(`[${isoNow()}] ❌❌❌❌❌ "${binaryName}" ❌❌❌❌❌`);
-      this.logger.error('[BinarySyncerService.executeTask:fail] taskId: %s, targetName: %s, %s',
-        task.taskId, task.targetName, task.error);
       if (err.name === 'HttpClientRequestTimeoutError'
         || err.name === 'ConnectionError'
         || err.name === 'ConnectTimeoutError') {
+        this.logger.warn('[BinarySyncerService.executeTask:fail] taskId: %s, targetName: %s, %s',
+          task.taskId, task.targetName, task.error);
         this.logger.warn(err);
       } else {
+        this.logger.error('[BinarySyncerService.executeTask:fail] taskId: %s, targetName: %s, %s',
+          task.taskId, task.targetName, task.error);
         this.logger.error(err);
       }
       await this.taskService.finishTask(task, TaskState.Fail, logs.join('\n'));

diff --git a/app/core/service/ChangesStreamService.ts b/app/core/service/ChangesStreamService.ts
@@ -102,7 +102,9 @@ export class ChangesStreamService extends AbstractService {
       }
     } catch (err) {
       this.logger.warn('[ChangesStreamService.executeTask:error] %s, exit now', err.message);
-      if (err.name === 'HttpClientRequestTimeoutError') {
+      if (err.name === 'HttpClientRequestTimeoutError'
+        || err.name === 'ConnectTimeoutError'
+        || err.name === 'BodyTimeoutError') {
         this.logger.warn(err);
       } else {
         this.logger.error(err);