Skip to content

Commit e0ccc47

Browse files
committed
fix(metadata): close store on exit
Signed-off-by: Chris Goller <[email protected]>
1 parent eddfcd5 commit e0ccc47

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

worker/base/worker.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -211,6 +211,9 @@ func NewWorker(ctx context.Context, opt WorkerOpt) (*Worker, error) {
211211

212212
func (w *Worker) Close() error {
213213
var rerr error
214+
if err := w.MetadataStore.Close(); err != nil {
215+
rerr = multierror.Append(rerr, err)
216+
}
214217
for _, provider := range w.NetworkProviders {
215218
if err := provider.Close(); err != nil {
216219
rerr = multierror.Append(rerr, err)

0 commit comments

Comments
 (0)