code refactoring

marcopiovanello · Feb 7, 2025 · ce2fb13 · ce2fb13
1 parent 99069fe
commit ce2fb13
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/server/subscription/task/runner.go b/server/subscription/task/runner.go
@@ -93,8 +93,11 @@ func (t *CronTaskRunner) Spawner(ctx context.Context) {
 
 // Stop a currently scheduled job
 func (t *CronTaskRunner) StopTask(id string) error {
-	t.running[id].Done <- struct{}{}
-	delete(t.running, id)
+	task := t.running[id]
+	if task != nil {
+		t.running[id].Done <- struct{}{}
+		delete(t.running, id)
+	}
 	return nil
 }