go.mod

@@ -1,3 +1,3 @@
-module git.canoozie.net/jer/task
+module git.canoozie.net/jer/task.git
 
 go 1.23.2

task.go

@@ -44,12 +44,11 @@ func (te *TaskExecutor) AddTask(task Task, interval time.Duration) {
 	case te.taskChan <- st:
 		log.Printf("Task %T queued up with interval %v\n", task, interval)
 	default:
-		log.Printf("Failed to add task %T with interval %v, channel full\n", task, interval)
+		log.Printf("Failed to add task $T with interval %v, channel full\n", task, interval)
 	}
 }
 
 func (te *TaskExecutor) Start() {
-	// Launch the task processor goroutine
 	go func() {
 		for {
 			select {
@@ -79,10 +78,6 @@ func (te *TaskExecutor) Start() {
 			}
 		}
 	}()
-	
-	// Process any tasks already in the channel before returning
-	// This ensures that when Start() returns, all queued tasks are in the tasks slice
-	time.Sleep(10 * time.Millisecond)
 }
 
 func (te *TaskExecutor) shouldRun(st *ScheduledTask, t time.Time) bool {

task_test.go

@@ -16,8 +16,6 @@ func (m *mockTask) Execute() error {
 func TestAddTask(t *testing.T) {
 	te := NewTaskExecutor(10)
 	te.AddTask(&mockTask{}, 1*time.Second)
-	te.Start()
-	// No need for explicit sleep now, as Start() ensures tasks are processed
 	if te.Len() != 1 {
 		t.Errorf("expected 1 task, got %d", te.Len())
 	}