Skip to content

Commit 7173652

Browse files
committed
sql: cleanup descriptor helper
A small refactor that clarifies the function's return values. Part of: #138691 Release note: None
1 parent 5c2f5e3 commit 7173652

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

pkg/sql/catalog/lease/lease.go

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -147,15 +147,16 @@ func (m *Manager) WaitForNoVersion(
147147
// from the KV layer.
148148
func (m *Manager) maybeGetDescriptorsWithoutValidation(
149149
ctx context.Context, ids descpb.IDs, existenceExpected bool,
150-
) (descs catalog.Descriptors, err error) {
151-
err = m.storage.db.KV().Txn(ctx, func(ctx context.Context, txn *kv.Txn) (err error) {
150+
) (catalog.Descriptors, error) {
151+
descs := make(catalog.Descriptors, 0, len(ids))
152+
153+
if err := m.storage.db.KV().Txn(ctx, func(ctx context.Context, txn *kv.Txn) (err error) {
152154
const isDescriptorRequired = false
153155
cr := m.storage.newCatalogReader(ctx)
154156
c, err := cr.GetByIDs(ctx, txn, ids, isDescriptorRequired, catalog.Any)
155157
if err != nil {
156158
return err
157159
}
158-
descs = make(catalog.Descriptors, 0, len(ids))
159160
for _, id := range ids {
160161
desc := c.LookupDescriptor(id)
161162
if desc == nil {
@@ -168,8 +169,11 @@ func (m *Manager) maybeGetDescriptorsWithoutValidation(
168169
}
169170
}
170171
return nil
171-
})
172-
return descs, err
172+
}); err != nil {
173+
return nil, err
174+
}
175+
176+
return descs, nil
173177
}
174178

175179
// countDescriptorsHeldBySessionIDs can be used to make sure certain nodes

0 commit comments

Comments
 (0)