diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/helper/ConnectionHelper.java b/airbyte-workers/src/main/java/io/airbyte/workers/helper/ConnectionHelper.java index 07a4f91691de..f77ff88d4896 100644 --- a/airbyte-workers/src/main/java/io/airbyte/workers/helper/ConnectionHelper.java +++ b/airbyte-workers/src/main/java/io/airbyte/workers/helper/ConnectionHelper.java @@ -74,7 +74,7 @@ public ConnectionRead updateConnection(final ConnectionUpdate connectionUpdate) .withMemoryRequest(connectionUpdate.getResourceRequirements().getMemoryRequest()) .withMemoryLimit(connectionUpdate.getResourceRequirements().getMemoryLimit())); } else { - newConnection.withResourceRequirements(workerConfigs.getResourceRequirements()); + newConnection.withResourceRequirements(persistedSync.getResourceRequirements()); } // update sync schedule