diff --git a/packages/backend-tasks/src/tasks/LocalTaskWorker.ts b/packages/backend-tasks/src/tasks/LocalTaskWorker.ts index 89f314a1ec..00765d7db0 100644 --- a/packages/backend-tasks/src/tasks/LocalTaskWorker.ts +++ b/packages/backend-tasks/src/tasks/LocalTaskWorker.ts @@ -64,6 +64,7 @@ export class LocalTaskWorker { this.logger.info(`Task worker finished: ${this.taskId}`); } catch (e) { this.logger.warn(`Task worker failed unexpectedly, ${e}`); + this.start(settings, options) } })(); } diff --git a/packages/backend-tasks/src/tasks/TaskWorker.ts b/packages/backend-tasks/src/tasks/TaskWorker.ts index d2269d8118..ba788b23ad 100644 --- a/packages/backend-tasks/src/tasks/TaskWorker.ts +++ b/packages/backend-tasks/src/tasks/TaskWorker.ts @@ -72,6 +72,7 @@ export class TaskWorker { this.logger.info(`Task worker finished: ${this.taskId}`); } catch (e) { + this.start(settings, options) this.logger.warn(`Task worker failed unexpectedly, ${e}`); } })();