From 633506ef06e1c25609a32d38080a303b5f8a7765 Mon Sep 17 00:00:00 2001 From: blakeromano-il Date: Mon, 16 May 2022 12:06:58 -0400 Subject: [PATCH] add restart to task workers Signed-off-by: blakeromano-il --- packages/backend-tasks/src/tasks/LocalTaskWorker.ts | 1 + packages/backend-tasks/src/tasks/TaskWorker.ts | 1 + 2 files changed, 2 insertions(+) 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}`); } })();