From 1e63cdbcdabcf6d411a127efb1b42bdfe76208b2 Mon Sep 17 00:00:00 2001 From: Christoph Kluge Date: Thu, 30 Jan 2025 17:14:17 +0100 Subject: [PATCH] fix: remove caching for footprint db field - footprints before first worker run are cached as empty, and are permanently returned as such until app restart - fixes Polar plot for running jobs #328 --- internal/repository/job.go | 6 ------ 1 file changed, 6 deletions(-) diff --git a/internal/repository/job.go b/internal/repository/job.go index 11f3b46..70d79d3 100644 --- a/internal/repository/job.go +++ b/internal/repository/job.go @@ -217,11 +217,6 @@ func (r *JobRepository) UpdateMetadata(job *schema.Job, key, val string) (err er func (r *JobRepository) FetchFootprint(job *schema.Job) (map[string]float64, error) { start := time.Now() - cachekey := fmt.Sprintf("footprint:%d", job.ID) - if cached := r.cache.Get(cachekey, nil); cached != nil { - job.Footprint = cached.(map[string]float64) - return job.Footprint, nil - } if err := sq.Select("job.footprint").From("job").Where("job.id = ?", job.ID). RunWith(r.stmtCache).QueryRow().Scan(&job.RawFootprint); err != nil { @@ -238,7 +233,6 @@ func (r *JobRepository) FetchFootprint(job *schema.Job) (map[string]float64, err return nil, err } - r.cache.Put(cachekey, job.Footprint, len(job.Footprint), 24*time.Hour) log.Debugf("Timer FetchFootprint %s", time.Since(start)) return job.Footprint, nil }