diff --git a/amp/shard_tracker.go b/amp/shard_tracker.go index 473447e4e4..477e141673 100644 --- a/amp/shard_tracker.go +++ b/amp/shard_tracker.go @@ -3,6 +3,7 @@ package amp import ( "crypto/rand" "encoding/binary" + "errors" "fmt" "sync" @@ -139,7 +140,7 @@ func (s *ShardTracker) CancelShard(pid uint64) error { c, ok := s.shards[pid] if !ok { - return fmt.Errorf("pid not found") + return errors.New("pid not found") } delete(s.shards, pid)