Handle duplicate event inserts gracefully when using Postgresql

Robban1980 · Sep 13, 2024 · dec0f4d · dec0f4d
1 parent 927e93d
commit dec0f4d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...es-persistence/src/main/java/com/netflix/conductor/postgres/dao/PostgresExecutionDAO.java b/...es-persistence/src/main/java/com/netflix/conductor/postgres/dao/PostgresExecutionDAO.java
@@ -903,7 +903,8 @@ private boolean insertEventExecution(Connection connection, EventExecution event
 
         String INSERT_EVENT_EXECUTION =
                 "INSERT INTO event_execution (event_handler_name, event_name, message_id, execution_id, json_data) "
-                        + "VALUES (?, ?, ?, ?, ?)";
+                        + "VALUES (?, ?, ?, ?, ?) "
+                        + "ON CONFLICT DO NOTHING";
         int count =
                 query(
                         connection,