From 73d404d3840101436edf291ed3e804eee7f49c5b Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Wed, 22 Nov 2023 14:43:02 +0800
Subject: [PATCH] friend

---
 pkg/common/db/tx/tx.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/common/db/tx/tx.go b/pkg/common/db/tx/tx.go
index baf9a9a5d..96b42b3b6 100644
--- a/pkg/common/db/tx/tx.go
+++ b/pkg/common/db/tx/tx.go
@@ -21,6 +21,7 @@ func (m *mongoTx) Transaction(ctx context.Context, fn func(ctx context.Context)
 	if err != nil {
 		return err
 	}
+	defer sess.EndSession(ctx)
 	_, err = sess.WithTransaction(ctx, func(ctx mongo.SessionContext) (interface{}, error) {
 		return nil, fn(ctx)
 	})