createorupdate

Author: YunchuWang

src/ScheduledTasks/Entity/Schedule.cs

@@ -20,7 +20,7 @@ class Schedule(ILogger<Schedule> logger) : TaskEntity<ScheduleState>
     readonly ILogger<Schedule> logger = logger ?? throw new ArgumentNullException(nameof(logger));
 
     /// <summary>
-    /// Creates a new schedule with the specified configuration.
+    /// Creates a new schedule with the specified configuration. If already exists, update it in place.
     /// </summary>
     /// <param name="context">The task entity context.</param>
     /// <param name="scheduleCreationOptions">The configuration options for creating the schedule.</param>
@@ -43,6 +43,7 @@ public void CreateSchedule(TaskEntityContext context, ScheduleCreationOptions sc
             this.State.ScheduleConfiguration = ScheduleConfiguration.FromCreateOptions(scheduleCreationOptions);
             this.TryStatusTransition(nameof(this.CreateSchedule), ScheduleStatus.Active);
 
+            this.State.RefreshScheduleRunExecutionToken();
             this.logger.CreatedSchedule(this.State.ScheduleConfiguration.ScheduleId);
 
             // Signal to run schedule immediately after creation and let runSchedule determine if it should run immediately

src/ScheduledTasks/Models/ScheduleTransitions.cs

@@ -13,6 +13,8 @@ static class ScheduleTransitions
         new Dictionary<ScheduleStatus, HashSet<ScheduleStatus>>
         {
             { ScheduleStatus.Uninitialized, new HashSet<ScheduleStatus> { ScheduleStatus.Active } },
+            { ScheduleStatus.Active, new HashSet<ScheduleStatus> { ScheduleStatus.Active } },
+            { ScheduleStatus.Paused, new HashSet<ScheduleStatus> { ScheduleStatus.Active } },
         };
 
     // define valid transitions for update schedule