feature: Not storing duplicate data in external storage (Netflix#153)

* Not storing duplicate data in external storage Signed-off-by: Simon Misencik <simon.misencik@gmail.com> * Add dependencies Signed-off-by: Simon Misencik <simon.misencik@gmail.com> --------- Signed-off-by: Simon Misencik <simon.misencik@gmail.com>
FRINXio · Oct 11, 2023 · ca31a75 · ca31a75
1 parent 30ba565
commit ca31a75
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/...rage/src/test/java/com/netflix/conductor/postgres/storage/PostgresPayloadStorageTest.java b/...rage/src/test/java/com/netflix/conductor/postgres/storage/PostgresPayloadStorageTest.java
@@ -268,22 +268,22 @@ private String getKey(String input) {
 
     private void assertCount(int expected) throws SQLException {
         try (PreparedStatement stmt =
-                        testPostgres
-                                .getDataSource()
-                                .getConnection()
-                                .prepareStatement(
-                                        "SELECT count(id) FROM external.external_payload");
-                ResultSet rs = stmt.executeQuery()) {
+                     testPostgres
+                             .getDataSource()
+                             .getConnection()
+                             .prepareStatement(
+                                     "SELECT count(id) FROM external.external_payload");
+             ResultSet rs = stmt.executeQuery()) {
             rs.next();
             assertEquals(expected, rs.getInt(1));
         }
     }
 
     private String getCreatedOn(String key) throws SQLException {
         try (Connection conn = testPostgres.getDataSource().getConnection();
-                PreparedStatement stmt =
-                        conn.prepareStatement(
-                                "SELECT created_on FROM external.external_payload WHERE id = ?")) {
+             PreparedStatement stmt =
+                     conn.prepareStatement(
+                             "SELECT created_on FROM external.external_payload WHERE id = ?")) {
             stmt.setString(1, key);
             try (ResultSet rs = stmt.executeQuery()) {
                 rs.next();