sealing: Use only non-assigned deals when selecting snap sectors

2023-06-23 18:40:46 +02:00 · 2023-06-23 18:40:46 +02:00 · c79acf9ca4
commit c79acf9ca4
parent a2431ff70a
1 changed files with 4 additions and 0 deletions
--- 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{