From a9f6b49f1c1f2b0f2fb661f78547cefb14e7d952 Mon Sep 17 00:00:00 2001
From: blakeromano-il <blake.romano@imaginelearning.com>
Date: Wed, 18 May 2022 09:09:22 -0400
Subject: [PATCH] reset counter, for loop, sleep 1s

Signed-off-by: blakeromano-il <blake.romano@imaginelearning.com>
---
 packages/backend-tasks/src/tasks/LocalTaskWorker.ts | 5 +++--
 packages/backend-tasks/src/tasks/TaskWorker.ts      | 5 +++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/packages/backend-tasks/src/tasks/LocalTaskWorker.ts b/packages/backend-tasks/src/tasks/LocalTaskWorker.ts
index c7ed759316..1326a6cd9d 100644
--- a/packages/backend-tasks/src/tasks/LocalTaskWorker.ts
+++ b/packages/backend-tasks/src/tasks/LocalTaskWorker.ts
@@ -40,10 +40,9 @@ export class LocalTaskWorker {
     this.logger.info(
       `Task worker starting: ${this.taskId}, ${JSON.stringify(settings)}`,
     );
-    const success = false;
     let attemptNum = 1;
     (async () => {
-      while (!success) {
+      for (;;) {
         try {
           if (settings.initialDelayDuration) {
             await this.sleep(
@@ -63,12 +62,14 @@ export class LocalTaskWorker {
             );
           }
           this.logger.info(`Task worker finished: ${this.taskId}`);
+          attemptNum = 0;
           break;
         } catch (e) {
           attemptNum += 1;
           this.logger.warn(
             `Task worker failed unexpectedly, attempt number ${attemptNum}, ${e}`,
           );
+          await sleep(Duration.fromISO('P1S'));
         }
       }
     })();
diff --git a/packages/backend-tasks/src/tasks/TaskWorker.ts b/packages/backend-tasks/src/tasks/TaskWorker.ts
index e74b8b9cdb..c19dedc117 100644
--- a/packages/backend-tasks/src/tasks/TaskWorker.ts
+++ b/packages/backend-tasks/src/tasks/TaskWorker.ts
@@ -51,10 +51,9 @@ export class TaskWorker {
     this.logger.info(
       `Task worker starting: ${this.taskId}, ${JSON.stringify(settings)}`,
     );
-    const success = false;
     let attemptNum = 1;
     (async () => {
-      while (!success) {
+      for (;;) {
         try {
           if (settings.initialDelayDuration) {
             await sleep(
@@ -73,12 +72,14 @@ export class TaskWorker {
           }
 
           this.logger.info(`Task worker finished: ${this.taskId}`);
+          attemptNum = 0;
           break;
         } catch (e) {
           attemptNum += 1;
           this.logger.warn(
             `Task worker failed unexpectedly, attempt number ${attemptNum}, ${e}`,
           );
+          await sleep(Duration.fromISO('P1S'));
         }
       }
     })();