fix(go.d): avoid blocking all jobs when stopping a slow job in the Manager

ilyam8 · ilyam8 · commit eaf7bd4e89ae · 2025-12-11T14:13:46.000+02:00
diff --git a/src/go/plugin/go.d/agent/jobmgr/manager.go b/src/go/plugin/go.d/agent/jobmgr/manager.go
@@ -259,24 +259,25 @@ func (m *Manager) runNotifyRunningJobs() {
 }
 
 func (m *Manager) startRunningJob(job *module.Job) {
+	m.stopRunningJob(job.FullName())
+
 	m.runningJobs.lock()
 	defer m.runningJobs.unlock()
 
-	if job, ok := m.runningJobs.lookup(job.FullName()); ok {
-		job.Stop()
-	}
-
 	go job.Start()
 	m.runningJobs.add(job.FullName(), job)
 }
 
 func (m *Manager) stopRunningJob(name string) {
 	m.runningJobs.lock()
-	defer m.runningJobs.unlock()
+	job, ok := m.runningJobs.lookup(name)
+	if ok {
+		m.runningJobs.remove(name)
+	}
+	m.runningJobs.unlock()
 
-	if job, ok := m.runningJobs.lookup(name); ok {
+	if ok {
 		job.Stop()
-		m.runningJobs.remove(name)
 	}
 }
 
