diff --git a/worker/base/worker.go b/worker/base/worker.go
index 8d402ff2fb1b..dcea020cb1f8 100644
--- a/worker/base/worker.go
+++ b/worker/base/worker.go
@@ -211,6 +211,9 @@ func NewWorker(ctx context.Context, opt WorkerOpt) (*Worker, error) {
 
 func (w *Worker) Close() error {
 	var rerr error
+	if err := w.MetadataStore.Close(); err != nil {
+		rerr = multierror.Append(rerr, err)
+	}
 	for _, provider := range w.NetworkProviders {
 		if err := provider.Close(); err != nil {
 			rerr = multierror.Append(rerr, err)