diff --git a/app/core/service/BinarySyncerService.ts b/app/core/service/BinarySyncerService.ts index a0981c82..c2f492d9 100644 --- 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 index 9a1a3355..b4b9c8da 100644 --- 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);