feat(jdbc): implementation of log repository

kestra-io · Jun 17, 2022 · 8b3fcbd · 8b3fcbd
1 parent 6daa39a
commit 8b3fcbd
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/jdbc/src/main/java/io/kestra/jdbc/repository/AbstractLogRepository.java b/jdbc/src/main/java/io/kestra/jdbc/repository/AbstractLogRepository.java
@@ -76,16 +76,8 @@ public List<LogEntry> findByExecutionIdAndTaskRunId(String executionId, String t
 
     @Override
     public LogEntry save(LogEntry log) {
-        Map<Field<Object>, Object> finalFields = this.jdbcRepository.persistFields(log);
-
-        this.jdbcRepository
-            .getDslContext()
-            .transaction(configuration -> DSL
-                .using(configuration)
-                .insertInto(this.jdbcRepository.getTable())
-                .set(finalFields)
-                .execute()
-            );
+        Map<Field<Object>, Object> fields = this.jdbcRepository.persistFields(log);
+        this.jdbcRepository.persist(log, fields);
 
         return log;
     }