fix: missing lagging

worker.go

@@ -94,6 +94,8 @@ func (w *LocalWorker) Start() error {
 }
 
 func (w *LocalWorker) SetManager(manager *Manager) {
+	w.mu.Lock()
+	defer w.mu.Unlock()
 	w.manager = manager
 }
 
@@ -111,7 +113,7 @@ func (w *LocalWorker) Stop() error {
 		stopChan <- true
 	}
 
-	if w.manager != nil {
+	if w.manager != nil && w.manager.logger != nil {
 		w.manager.logger.Info("Worker stopped", "worker", w.ID)
 	}