Merge pull request #11002 from filecoin-project/feat/dealbounds-calc

sealing: Use only non-assigned deals when selecting snap sectors
filecoin-project · Jun 28, 2023 · 30a9f63 · 30a9f63
2 parents 2df1697 + c79acf9
commit 30a9f63
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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{