diff --git a/node/app/data_worker_node.go b/node/app/data_worker_node.go
index 0439a1b..f357d8b 100644
--- a/node/app/data_worker_node.go
+++ b/node/app/data_worker_node.go
@@ -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