Skip to content

Commit

Permalink
Do not log context cancelled as error
Browse files Browse the repository at this point in the history
  • Loading branch information
mhmxs committed Jan 10, 2025
1 parent a4169b9 commit c11ff0a
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions pkg/server/kv.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package server

import (
"context"
"errors"

"github.com/sirupsen/logrus"
"go.etcd.io/etcd/api/v3/etcdserverpb"
Expand Down Expand Up @@ -50,7 +51,9 @@ func (k *KVServerBridge) Range(ctx context.Context, r *etcdserverpb.RangeRequest

resp, err := k.limited.Range(ctx, r)
if err != nil {
logrus.Errorf("error while range on %s %s: %v", r.Key, r.RangeEnd, err)
if !errors.Is(err, context.Canceled) {
logrus.Errorf("error while range on %s %s: %v", r.Key, r.RangeEnd, err)
}
return nil, err
}

Expand Down Expand Up @@ -103,7 +106,9 @@ func (k *KVServerBridge) DeleteRange(ctx context.Context, r *etcdserverpb.Delete
func (k *KVServerBridge) Txn(ctx context.Context, r *etcdserverpb.TxnRequest) (*etcdserverpb.TxnResponse, error) {
res, err := k.limited.Txn(ctx, r)
if err != nil {
logrus.Errorf("error in txn %s: %v", r, err)
if !errors.Is(err, context.Canceled) {
logrus.Errorf("error in txn %s: %v", r, err)
}
}
return res, err
}
Expand Down

0 comments on commit c11ff0a

Please sign in to comment.