diff --git a/pkg/mining/manager.go b/pkg/mining/manager.go index 2cb43d4..c3a971c 100644 --- a/pkg/mining/manager.go +++ b/pkg/mining/manager.go @@ -660,16 +660,16 @@ func (m *Manager) collectSingleMinerStats(miner Miner, minerType string, now tim // Persist to database if enabled if databaseEnabled { - dbPoint := database.HashratePoint{ + databasePoint := database.HashratePoint{ Timestamp: point.Timestamp, Hashrate: point.Hashrate, } // Create a new context for DB writes (original context is from retry loop) - dbCtx, dbCancel := context.WithTimeout(context.Background(), statsCollectionTimeout) - if err := database.InsertHashratePoint(dbCtx, minerName, minerType, dbPoint, database.ResolutionHigh); err != nil { + databaseContext, databaseCancel := context.WithTimeout(context.Background(), statsCollectionTimeout) + if err := database.InsertHashratePoint(databaseContext, minerName, minerType, databasePoint, database.ResolutionHigh); err != nil { logging.Warn("failed to persist hashrate", logging.Fields{"miner": minerName, "error": err}) } - dbCancel() + databaseCancel() } // Emit stats event for real-time WebSocket updates