fix: update task run scheduler migrator

Author: Arta Asadi

jobs/post-install-job/job/migrations/tasks/migrator.go

@@ -187,6 +187,7 @@ func (m Migration) Run(ctx context.Context, conf config.MigratorConfig, logger *
 			}
 
 			if err = dbm.ORM.Create(&models.TaskRunSchedule{
+				ID:        runSchedule.ID,
 				TaskID:    task.ID,
 				Params:    paramsJsonb,
 				Frequency: frequencyFloat,

services/tasks/db/models/task.go

@@ -45,8 +45,8 @@ type TaskConfigSecret struct {
 }
 
 type TaskRunSchedule struct {
-	SchedulerID string `gorm:"primarykey"`
-	TaskID      string `gorm:"primarykey"`
-	Params      pgtype.JSONB
-	Frequency   float64
+	ID        string `gorm:"primarykey"`
+	TaskID    string `gorm:"primarykey"`
+	Params    pgtype.JSONB
+	Frequency float64
 }

services/tasks/scheduler/create_task.go

@@ -40,7 +40,7 @@ func (s *MainScheduler) createTasks(ctx context.Context) error {
 			return err
 		}
 		for _, runSchedule := range runSchedules {
-			lastRun, err := s.db.FetchLastTaskRunsByTaskSchedulerID(task.ID, runSchedule.SchedulerID)
+			lastRun, err := s.db.FetchLastTaskRunsByTaskSchedulerID(task.ID, runSchedule.ID)
 			if err != nil {
 				return err
 			}
@@ -54,7 +54,7 @@ func (s *MainScheduler) createTasks(ctx context.Context) error {
 				TaskID:      task.ID,
 				Status:      models.TaskRunStatusCreated,
 				TriggerType: models.TriggerTypeScheduled,
-				TriggeredBy: runSchedule.SchedulerID,
+				TriggeredBy: runSchedule.ID,
 			}
 
 			err = newRun.Result.Set([]byte("{}"))

services/tasks/worker/model.go

@@ -29,6 +29,7 @@ type Interval struct {
 }
 
 type TaskRunSchedule struct {
+	ID        string         `yaml:"id"`
 	Params    map[string]any `yaml:"params"`
 	Frequency string         `yaml:"frequency"`
 }