fix pipelineStats

filecoin-project · Feb 20, 2025 · e81a30c · e81a30c
1 parent 10f3686
commit e81a30c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/market/mk12/cidgravity.go b/market/mk12/cidgravity.go
@@ -305,8 +305,7 @@ func (m *MK12) prepareCidGravityPayload(ctx context.Context, deal *ProviderDealS
 		AfterFindDealSectorNotNull int `db:"after_find_deal_sector_not_null"`
 	}
 
-	err = m.db.Select(ctx, &stats, `SELECT 
-										COUNT(*) FILTER (WHERE started = FALSE AND offline = TRUE) AS not_started_offline,
+	err = m.db.Select(ctx, &pipelineStats, `SELECT COUNT(*) FILTER (WHERE started = FALSE AND offline = TRUE) AS not_started_offline,
 										COUNT(*) FILTER (WHERE started = FALSE AND offline = FALSE) AS not_started_online,
 										COUNT(*) FILTER (WHERE after_commp = TRUE AND after_psd = FALSE) AS after_commp_not_after_psd,
 										COUNT(*) FILTER (WHERE after_find_deal = TRUE AND sector IS NOT NULL) AS after_find_deal_sector_not_null