shift to avoid time alignment ingestion problems

arduino · Sep 17, 2024 · a1988d3 · a1988d3
1 parent edb6212
commit a1988d3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/business/tsextractor/tsextractor.go b/business/tsextractor/tsextractor.go
@@ -50,6 +50,10 @@ func computeTimeAlignment(resolutionSeconds, timeWindowInMinutes int) (time.Time
 		resolutionSeconds = 300 // Align to 5 minutes
 	}
 	to := time.Now().Truncate(time.Duration(resolutionSeconds) * time.Second).UTC()
+	if resolutionSeconds <= 900 {
+		// Shift time window to avoid missing data
+		to = to.Add(-time.Duration(300) * time.Second)
+	}
 	from := to.Add(-time.Duration(timeWindowInMinutes) * time.Minute)
 	return from, to
 }