use maybeAttemptId instead of connectionUpdaterInput.getAttemptNumber

airbytehq · Jan 24, 2022 · 67efb4d · 67efb4d
1 parent 9a0f4ef
commit 67efb4d
Showing 1 changed file with 2 additions and 2 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
@@ -152,11 +152,11 @@ public void run(final ConnectionUpdaterInput connectionUpdaterInput) throws Retr
                     af.getActivityType(),
                     af.getCause(),
                     maybeJobId.get(),
-                    connectionUpdaterInput.getAttemptNumber()));
+                    maybeAttemptId.get()));
                 throw childWorkflowFailure;
               } else {
                 failures.add(
-                    FailureHelper.unknownOriginFailure(childWorkflowFailure.getCause(), maybeJobId.get(), connectionUpdaterInput.getAttemptNumber()));
+                    FailureHelper.unknownOriginFailure(childWorkflowFailure.getCause(), maybeJobId.get(), maybeAttemptId.get()));
                 throw childWorkflowFailure;
               }
             }