From 870fafb5add53a441867974dc95c779fbcc3da0f Mon Sep 17 00:00:00 2001
From: Yihang Wang <wangyihanger@gmail.com>
Date: Fri, 8 Mar 2024 16:46:18 +0800
Subject: [PATCH] fix: change ID to RunID

---
 scheduler.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/scheduler.go b/scheduler.go
index 0ab08e7..fd17bb4 100644
--- a/scheduler.go
+++ b/scheduler.go
@@ -16,7 +16,7 @@ import (
 
 // Scheduler is a task scheduler
 type Scheduler struct {
-	ID                       string
+	RunID                    string
 	NumWorkers               int
 	OutputFilePath           string
 	OutputFd                 io.WriteCloser
@@ -45,7 +45,7 @@ type Scheduler struct {
 func NewScheduler() *Scheduler {
 	id := uuid.New().String()
 	return (&Scheduler{
-		ID:                       id,
+		RunID:                    id,
 		NumWorkers:               1,
 		Metadata:                 make(map[string]interface{}),
 		MaxRetries:               4,
@@ -186,7 +186,7 @@ func (s *Scheduler) Submit(task Task) {
 	index := s.CurrentIndex.Load()
 	if (index % s.NumShards) == s.Shard {
 		s.taskWg.Add(1)
-		s.TaskChan <- NewBasicTask(index, s.ID, task)
+		s.TaskChan <- NewBasicTask(index, s.RunID, task)
 	}
 	s.CurrentIndex.Add(1)
 }