diff --git a/beacon-chain/blockchain/process_block_helpers.go b/beacon-chain/blockchain/process_block_helpers.go index b323cf73582e..729864b98ae7 100644 --- a/beacon-chain/blockchain/process_block_helpers.go +++ b/beacon-chain/blockchain/process_block_helpers.go @@ -6,7 +6,6 @@ import ( "fmt" "github.com/pkg/errors" - "github.com/prysmaticlabs/prysm/v3/beacon-chain/core/helpers" doublylinkedtree "github.com/prysmaticlabs/prysm/v3/beacon-chain/forkchoice/doubly-linked-tree" forkchoicetypes "github.com/prysmaticlabs/prysm/v3/beacon-chain/forkchoice/types" "github.com/prysmaticlabs/prysm/v3/beacon-chain/state" @@ -317,23 +316,6 @@ func (s *Service) insertFinalizedDeposits(ctx context.Context, fRoot [32]byte) e return nil } -// The deletes input attestations from the attestation pool, so proposers don't include them in a block for the future. -func (s *Service) deletePoolAtts(atts []*ethpb.Attestation) error { - for _, att := range atts { - if helpers.IsAggregated(att) { - if err := s.cfg.AttPool.DeleteAggregatedAttestation(att); err != nil { - return err - } - } else { - if err := s.cfg.AttPool.DeleteUnaggregatedAttestation(att); err != nil { - return err - } - } - } - - return nil -} - // This ensures that the input root defaults to using genesis root instead of zero hashes. This is needed for handling // fork choice justification routine. func (s *Service) ensureRootNotZeros(root [32]byte) [32]byte { diff --git a/beacon-chain/blockchain/receive_block.go b/beacon-chain/blockchain/receive_block.go index 0a3640771685..8141fdf718f2 100644 --- a/beacon-chain/blockchain/receive_block.go +++ b/beacon-chain/blockchain/receive_block.go @@ -145,11 +145,6 @@ func (s *Service) ReceiveAttesterSlashing(ctx context.Context, slashing *ethpb.A } func (s *Service) handlePostBlockOperations(b interfaces.BeaconBlock) error { - // Delete the processed block attestations from attestation pool. - if err := s.deletePoolAtts(b.Body().Attestations()); err != nil { - return err - } - // Mark block exits as seen so we don't include same ones in future blocks. for _, e := range b.Body().VoluntaryExits() { s.cfg.ExitPool.MarkIncluded(e)