From ce2fb13ef2cafa16c6ac010ec6916672fb9c3be4 Mon Sep 17 00:00:00 2001
From: marcobaobao <marco.piovanello@gmail.com>
Date: Fri, 7 Feb 2025 10:13:35 +0100
Subject: [PATCH] code refactoring

---
 server/subscription/task/runner.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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
 }