friend

2 years ago · 73d404d384
parent dbeeb6d2b1
commit 73d404d384
1 changed files with 1 additions and 0 deletions
--- 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)
 	})