fix: fix expired check

ipfs-force-community · Nov 4, 2022 · 80c05cc · 80c05cc
1 parent 6ed6295
commit 80c05cc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/storageprovider/deal_tracker.go b/storageprovider/deal_tracker.go
@@ -90,7 +90,7 @@ func (dealTracker *DealTracker) checkPreCommitAndCommit(ctx metrics.MetricsCtx,
 	curHeight := ts.Height()
 
 	for _, deal := range deals {
-		if deal.Proposal.StartEpoch > curHeight {
+		if deal.Proposal.StartEpoch < curHeight {
 			err = dealTracker.storageRepo.UpdateDealStatus(ctx, deal.ProposalCid, storagemarket.StorageDealExpired, "")
 			if err != nil {
 				return fmt.Errorf("update deal %d status to of miner %s expired %w", deal.DealID, addr, err)