diff --git a/beacon-chain/db/kv/attestations.go b/beacon-chain/db/kv/attestations.go index 4bf2df1686..9642e79773 100644 --- a/beacon-chain/db/kv/attestations.go +++ b/beacon-chain/db/kv/attestations.go @@ -95,7 +95,7 @@ func (k *Store) HasAttestation(ctx context.Context, attDataRoot [32]byte) bool { func (k *Store) DeleteAttestation(ctx context.Context, attDataRoot [32]byte) error { ctx, span := trace.StartSpan(ctx, "BeaconDB.DeleteAttestation") defer span.End() - return k.db.Batch(func(tx *bolt.Tx) error { + return k.db.Update(func(tx *bolt.Tx) error { bkt := tx.Bucket(attestationsBucket) enc := bkt.Get(attDataRoot[:]) if enc == nil { @@ -151,7 +151,7 @@ func (k *Store) SaveAttestation(ctx context.Context, att *ethpb.Attestation) err return err } - err := k.db.Batch(func(tx *bolt.Tx) error { + err := k.db.Update(func(tx *bolt.Tx) error { attDataRoot, err := ssz.HashTreeRoot(att.Data) if err != nil { return err diff --git a/beacon-chain/db/kv/blocks.go b/beacon-chain/db/kv/blocks.go index f97e8da737..5873272413 100644 --- a/beacon-chain/db/kv/blocks.go +++ b/beacon-chain/db/kv/blocks.go @@ -206,7 +206,7 @@ func (k *Store) HasBlock(ctx context.Context, blockRoot [32]byte) bool { func (k *Store) DeleteBlock(ctx context.Context, blockRoot [32]byte) error { ctx, span := trace.StartSpan(ctx, "BeaconDB.DeleteBlock") defer span.End() - return k.db.Batch(func(tx *bolt.Tx) error { + return k.db.Update(func(tx *bolt.Tx) error { bkt := tx.Bucket(blocksBucket) enc := bkt.Get(blockRoot[:]) if enc == nil {