Skip to content
This repository was archived by the owner on Aug 23, 2023. It is now read-only.

Commit fa7dd52

Browse files
committed
idx: remove no longer needed safety precaution
see #877
1 parent e04411d commit fa7dd52

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

idx/cassandra/cassandra.go

-7
Original file line numberDiff line numberDiff line change
@@ -296,13 +296,6 @@ func (c *CasIdx) AddOrUpdate(data *schema.MetricData, partition int32) idx.Archi
296296
return archive
297297
}
298298

299-
// This is just a safety precaution to prevent corrupt index entries.
300-
// This ensures that the index entry always contains the correct metricDefinition data.
301-
if inMemory {
302-
archive.MetricDefinition = *schema.MetricDefinitionFromMetricData(data)
303-
archive.MetricDefinition.Partition = partition
304-
}
305-
306299
// if the entry has not been saved for 1.5x updateInterval
307300
// then perform a blocking save.
308301
if archive.LastSave < (now - updateInterval32 - updateInterval32/2) {

0 commit comments

Comments
 (0)