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
index f049fdd949cad..5b4cd922695de 100644
--- 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
@@ -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;
               }
             }