diff --git a/cassandra-persistence/src/main/java/com/netflix/conductor/cassandra/dao/CassandraExecutionDAO.java b/cassandra-persistence/src/main/java/com/netflix/conductor/cassandra/dao/CassandraExecutionDAO.java
index 50bf1a3705..ce564af0ab 100644
--- a/cassandra-persistence/src/main/java/com/netflix/conductor/cassandra/dao/CassandraExecutionDAO.java
+++ b/cassandra-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")));