fix: always set task_data via JdbcCustomization method (#495)

Fixes #452
kagkarlsson · May 30, 2024 · f243d5e · f243d5e
1 parent 1ff9ff4
commit f243d5e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/JdbcTaskRepository.java b/db-scheduler/src/main/java/com/github/kagkarlsson/scheduler/jdbc/JdbcTaskRepository.java
@@ -218,7 +218,8 @@ public Instant replace(Execution toBeReplaced, SchedulableInstance newInstance)
               ps.setInt(index++, 0); // consecutive_failures
               jdbcCustomization.setInstant(ps, index++, newExecutionTime); // execution_time
               // may cause datbase-specific problems, might have to use setNull instead
-              ps.setObject(index++, serializer.serialize(newData)); // task_data
+              jdbcCustomization.setTaskData(
+                  ps, index++, serializer.serialize(newData)); // task_data
               ps.setString(index++, toBeReplaced.taskInstance.getTaskName()); // task_name
               ps.setString(index++, toBeReplaced.taskInstance.getId()); // task_instance
               ps.setLong(index++, toBeReplaced.version); // version
@@ -485,7 +486,7 @@ private boolean rescheduleInternal(
               if (newData != null) {
                 // may cause datbase-specific problems, might have to use setNull instead
                 // FIXLATER: optionally support bypassing serializer if byte[] already
-                ps.setObject(index++, serializer.serialize(newData.data));
+                jdbcCustomization.setTaskData(ps, index++, serializer.serialize(newData.data));
               }
               ps.setString(index++, execution.taskInstance.getTaskName());
               ps.setString(index++, execution.taskInstance.getId());