Make sure to clone metadata in LR before changing

This hit the race detector
authzed · Dec 8, 2023 · 3ffaec7 · 3ffaec7
1 parent 90be4e6
commit 3ffaec7
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/internal/graph/checkingresourcestream.go b/internal/graph/checkingresourcestream.go
@@ -542,9 +542,10 @@ func (crs *checkingResourceStream) runProcess(alwaysProcess bool) (bool, error)
 func (crs *checkingResourceStream) addSkippedDispatchCountToBePublished(metadata *v1.ResponseMeta) *v1.ResponseMeta {
 	dispatchCount := crs.dispatchesToBeReported.Swap(0)
 	cachedDispatchCount := crs.cachedDispatchesToBeReported.Swap(0)
-	metadata.DispatchCount += dispatchCount
-	metadata.CachedDispatchCount += cachedDispatchCount
-	return metadata
+	cloned := metadata.CloneVT()
+	cloned.DispatchCount += dispatchCount
+	cloned.CachedDispatchCount += cachedDispatchCount
+	return cloned
 }
 
 // spawnIfAvailable spawns a processing working, if the concurrency limit has not been reached.