fix(core): serialize duration as strings

core/src/main/java/io/kestra/core/serializers/JacksonMapper.java

@@ -121,6 +121,7 @@ public static ObjectMapper ofIon() {
     private static ObjectMapper configure(ObjectMapper mapper) {
         return mapper
             .configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false)
+            .configure(SerializationFeature.WRITE_DURATIONS_AS_TIMESTAMPS, false)
             .setSerializationInclusion(JsonInclude.Include.NON_NULL)
             .registerModule(new JavaTimeModule())
             .registerModule(new Jdk8Module())

core/src/test/java/io/kestra/plugin/core/kv/SetTest.java

@@ -209,8 +209,7 @@ void typeSpecified() throws Exception {
         assertThat(kv.getValue(TEST_KEY).get().value(), is(Instant.parse("2023-05-02T01:02:03Z")));
 
         set.toBuilder().value("P1DT5S").kvType(KVType.DURATION).build().run(runContext);
-        // TODO Hack meanwhile we handle duration serialization as currently they are stored as bigint...
-        assertThat((long) Double.parseDouble(kv.getValue(TEST_KEY).get().value().toString()), is(Duration.ofDays(1).plus(Duration.ofSeconds(5)).toSeconds()));
+        assertThat(kv.getValue(TEST_KEY).get().value(), is(Duration.ofDays(1).plus(Duration.ofSeconds(5))));
 
         set.toBuilder().value("[{\"some\":\"value\"},{\"another\":\"value\"}]").kvType(KVType.JSON).build().run(runContext);
         assertThat(kv.getValue(TEST_KEY).get().value(), is(List.of(Map.of("some", "value"), Map.of("another", "value"))));

jdbc-h2/src/main/resources/migrations/h2/V_1_23__execution_duration.sql

@@ -0,0 +1,2 @@
+alter table executions drop column "state_duration";
+alter table executions add column "state_duration" VARCHAR(150) NOT NULL GENERATED ALWAYS AS (JQ_STRING("value", '.state.duration'));

jdbc-mysql/src/main/resources/migrations/mysql/V_1_23__execution_duration.sql

@@ -0,0 +1,2 @@
+alter table `executions` drop column `state_duration`;
+alter table `executions` add column `state_duration` VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value ->> '$.state.duration'):

jdbc-postgres/src/main/resources/migrations/postgres/V_1_23__execution_duration.sql

@@ -0,0 +1,2 @@
+alter table executions drop column state_duration;
+alter table executions add column state_duration VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value #>> '{state, duration}');