diff --git a/airbyte-scheduler/persistence/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java b/airbyte-scheduler/persistence/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java
index 6fd4f22cb3d7..8feceddbda9a 100644
--- a/airbyte-scheduler/persistence/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java
+++ b/airbyte-scheduler/persistence/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java
@@ -313,15 +313,6 @@ public Optional<String> getAttemptTemporalWorkflowId(final long jobId, final int
   @Override
   public <T> void writeOutput(final long jobId, final int attemptNumber, final T output) throws IOException {
     final OffsetDateTime now = OffsetDateTime.ofInstant(timeSupplier.get(), ZoneOffset.UTC);
-    writeOutputToAttemptTable(jobId, attemptNumber, output, now);
-    // writeOutputToSyncStateTable(jobId, output, now);
-  }
-
-  private <T> void writeOutputToAttemptTable(final long jobId,
-                                             final int attemptNumber,
-                                             final T output,
-                                             final OffsetDateTime now)
-      throws IOException {
     jobDatabase.transaction(
         ctx -> ctx.update(ATTEMPTS)
             .set(ATTEMPTS.OUTPUT, JSONB.valueOf(Jsons.serialize(output)))