Merge pull request #3278 from Netflix/tasks/MWI-4643

Set scheduledTime and startTime with currentTime for all system tasks
Netflix · Oct 10, 2022 · ffa4210 · ffa4210
2 parents b5e3f1b + cc7b330
commit ffa4210
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...-persistence/src/main/java/com/netflix/conductor/cassandra/dao/CassandraExecutionDAO.java b/...-persistence/src/main/java/com/netflix/conductor/cassandra/dao/CassandraExecutionDAO.java
@@ -192,7 +192,9 @@ public List<TaskModel> createTasks(List<TaskModel> tasks) {
             // update the task_lookup table
             tasks.forEach(
                     task -> {
-                        task.setScheduledTime(System.currentTimeMillis());
+                        if (task.getScheduledTime() == 0) {
+                            task.setScheduledTime(System.currentTimeMillis());
+                        }
                         session.execute(
                                 updateTaskLookupStatement.bind(
                                         workflowUUID, toUUID(task.getTaskId(), "Invalid task id")));