diff --git a/server/subscription/task/runner.go b/server/subscription/task/runner.go index e02f0b8..a9823a2 100644 --- 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 }