Add missing continue as new

benmoriceau · benmoriceau · commit 96067af68d98 · 2022-02-24T10:22:48.000-08:00
diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/ConnectionManagerWorkflowImpl.java b/airbyte-workers/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);
         }
       }
     });

Original file line number	Diff line number	Diff line change
`@@ -177,11 +177,13 @@ private CancellationScope generateSyncWorkflowRunnable(ConnectionUpdaterInput co`
`177`	`177`	`workflowInternalState.getJobId(),`
`178`	`178`	`workflowInternalState.getAttemptId()));`
`179`	`179`	`reportFailure(connectionUpdaterInput, standardSyncOutput);`
	`180`	`+ prepareForNextRunAndContinueAsNew(connectionUpdaterInput);`
`180`	`181`	`} else {`
`181`	`182`	`workflowInternalState.getFailures().add(`
`182`	`183`	`FailureHelper.unknownOriginFailure(childWorkflowFailure.getCause(), workflowInternalState.getJobId(),`
`183`	`184`	`workflowInternalState.getAttemptId()));`
`184`	`185`	`reportFailure(connectionUpdaterInput, standardSyncOutput);`
	`186`	`+ prepareForNextRunAndContinueAsNew(connectionUpdaterInput);`
`185`	`187`	`}`
`186`	`188`	`}`
`187`	`189`	`});`