diff --git a/storage/pipeline/input.go b/storage/pipeline/input.go
index 7eb02ae27..6fdae03d9 100644
--- a/storage/pipeline/input.go
+++ b/storage/pipeline/input.go
@@ -630,6 +630,10 @@ func (m *Sealing) pendingPieceEpochBounds() []pieceBound {
 	boundsByEpoch := map[abi.ChainEpoch]*pieceBound{}
 
 	for ppi, piece := range m.pendingPieces {
+		if piece.assigned {
+			continue
+		}
+
 		// start bound on deal end
 		if boundsByEpoch[piece.deal.DealProposal.EndEpoch] == nil {
 			boundsByEpoch[piece.deal.DealProposal.EndEpoch] = &pieceBound{