Add missing continue as new

airbytehq · Feb 24, 2022 · 96067af · 96067af
1 parent 77ea0e0
commit 96067af
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...s/src/main/java/io/airbyte/workers/temporal/scheduling/ConnectionManagerWorkflowImpl.java b/...s/src/main/java/io/airbyte/workers/temporal/scheduling/ConnectionManagerWorkflowImpl.java
@@ -177,11 +177,13 @@ private CancellationScope generateSyncWorkflowRunnable(ConnectionUpdaterInput co
               workflowInternalState.getJobId(),
               workflowInternalState.getAttemptId()));
           reportFailure(connectionUpdaterInput, standardSyncOutput);
+          prepareForNextRunAndContinueAsNew(connectionUpdaterInput);
         } else {
           workflowInternalState.getFailures().add(
               FailureHelper.unknownOriginFailure(childWorkflowFailure.getCause(), workflowInternalState.getJobId(),
                   workflowInternalState.getAttemptId()));
           reportFailure(connectionUpdaterInput, standardSyncOutput);
+          prepareForNextRunAndContinueAsNew(connectionUpdaterInput);
         }
       }
     });