From c79acf9ca4e5ac4faeca1b28f50e370f6dd92197 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Fri, 23 Jun 2023 18:40:46 +0200 Subject: [PATCH] sealing: Use only non-assigned deals when selecting snap sectors --- storage/pipeline/input.go | 4 ++++ 1 file changed, 4 insertions(+) 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{