diff --git a/manager.go b/manager.go
index 6c277d5ddc1c2b7759c437e7805b11dc95648db6..a3af4ebaed6de33537c20c307da731dc47ec4995 100644
--- a/manager.go
+++ b/manager.go
@@ -169,6 +169,7 @@ func (m *Manager) AddWorker(worker Worker) error {
 
 	// add worker to workerMap
 	m.workerMap[worker.GetID()] = worker
+	worker.SetManager(m)
 
 	return m.checkAndSetRunningState()
 }