diff --git a/tasks/actorstate/miner/sector_deals.go b/tasks/actorstate/miner/sector_deals.go index b3b206e3..7d37522f 100644 --- a/tasks/actorstate/miner/sector_deals.go +++ b/tasks/actorstate/miner/sector_deals.go @@ -12,8 +12,11 @@ import ( minermodel "github.com/filecoin-project/lily/model/actors/miner" "github.com/filecoin-project/lily/tasks/actorstate" "github.com/filecoin-project/lily/tasks/actorstate/miner/extraction" + logging "github.com/ipfs/go-log/v2" ) +var logger = logging.Logger("lily/tasks/sectordeals") + type SectorDealsExtractor struct{} func (SectorDealsExtractor) Extract(ctx context.Context, a actorstate.ActorInfo, node actorstate.ActorStateAPI) (model.Persistable, error) { @@ -58,6 +61,11 @@ func ExtractSectorDealsModel(ctx context.Context, ec extraction.State) (minermod for i := range sectorChanges.Snapped { sectors = append(sectors, §orChanges.Snapped[i].To) } + logger.Errorf("Get the number of sector changes: added %v", len(sectorChanges.Added)) + logger.Errorf("Get the number of sector changes: snapped %v", len(sectorChanges.Snapped)) + logger.Errorf("Get the number of sector changes: extended %v", len(sectorChanges.Extended)) + logger.Errorf("Get the number of sector changes: removed %v", len(sectorChanges.Removed)) + } for _, sector := range sectors {