add timezone to csv file

airbytehq · Feb 21, 2024 · 0e89330 · 0e89330
1 parent b9b77ec
commit 0e89330
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...java/io/airbyte/cdk/integrations/destination/s3/csv/StagingDatabaseCsvSheetGenerator.java b/...java/io/airbyte/cdk/integrations/destination/s3/csv/StagingDatabaseCsvSheetGenerator.java
@@ -62,14 +62,15 @@ public List<Object> getDataRow(final UUID id, final String formattedString, fina
     if (useDestinationsV2Columns) {
       return List.of(
           id,
-          Timestamp.from(Instant.ofEpochMilli(emittedAt)),
+          // TODO check that this is safe to apply to ALL destinations
+          Instant.ofEpochMilli(emittedAt),
           "",
           formattedString);
     } else {
       return List.of(
           id,
           formattedString,
-          Timestamp.from(Instant.ofEpochMilli(emittedAt)));
+          Instant.ofEpochMilli(emittedAt));
     }
   }