Remove unnecessary method

airbytehq · Oct 25, 2021 · 9e0dc1e · 9e0dc1e
1 parent a1c950c
commit 9e0dc1e
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/...ler/persistence/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java b/...ler/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)))