move deferred Stop() to Start()

This commit is contained in:
Vasyl Tretiakov 2025-10-21 21:39:10 +03:00
parent 3da121978d
commit c46373ffc5

View File

@ -70,6 +70,8 @@ func (n *DataWorkerNode) Start() error {
n.logger.Info("data worker node started", zap.Uint("core_id", n.coreId))
defer n.Stop()
<-n.quit
return nil