Skip to content

Commit 35c14eb

Browse files
magik6krvagg
authored andcommitted
fix gc mark snapdeal sector query (#607)
1 parent 9641aca commit 35c14eb

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

tasks/gc/storage_gc_mark.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -331,7 +331,7 @@ func (s *StorageGCMark) Do(taskID harmonytask.TaskID, stillOwned func() bool) (d
331331
}
332332

333333
var minerIDs []int64
334-
if err = s.db.Select(ctx, &minerIDs, `SELECT DISTINCT sp_id FROM sectors_meta WHERE orig_unsealed_cid != cur_sealed_cid`); err != nil {
334+
if err = s.db.Select(ctx, &minerIDs, `SELECT DISTINCT sp_id FROM sectors_meta WHERE orig_sealed_cid != cur_sealed_cid`); err != nil {
335335
return false, xerrors.Errorf("distinct miners from snap sectors: %w", err)
336336
}
337337

@@ -355,12 +355,12 @@ func (s *StorageGCMark) Do(taskID harmonytask.TaskID, stillOwned func() bool) (d
355355
finalityMinerStates[abi.ActorID(mID)] = mState
356356
}
357357

358-
// SELECT sp_id, sector_num FROM sectors_meta WHERE orig_unsealed_cid != cur_sealed_cid
358+
// SELECT sp_id, sector_num FROM sectors_meta WHERE orig_sealed_cid != cur_sealed_cid
359359
var snapSectors []struct {
360360
SpID int64 `db:"sp_id"`
361361
SectorNum int64 `db:"sector_num"`
362362
}
363-
err = s.db.Select(ctx, &snapSectors, `SELECT sp_id, sector_num FROM sectors_meta WHERE orig_unsealed_cid != cur_sealed_cid ORDER BY sp_id, sector_num`)
363+
err = s.db.Select(ctx, &snapSectors, `SELECT sp_id, sector_num FROM sectors_meta WHERE orig_sealed_cid != cur_sealed_cid ORDER BY sp_id, sector_num`)
364364
if err != nil {
365365
return false, xerrors.Errorf("select snap sectors: %w", err)
366366
}

0 commit comments

Comments
 (0)