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)
 	})