Fix wrong reference when updating direct mirrors (#252)

emberstack · Jan 9, 2022 · be1ac65 · be1ac65
1 parent c1f3e0f
commit be1ac65
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/ES.Kubernetes.Reflector/Core/Mirroring/ResourceMirror.cs b/src/ES.Kubernetes.Reflector/Core/Mirroring/ResourceMirror.cs
@@ -219,7 +219,7 @@ private async Task HandleUpsert(TResource resource, WatchEventType eventType, Ca
             ReflectorProperties sourceProperties;
             if (!_propertiesCache.TryGetValue(sourceRef, out var sourceProps))
             {
-                var source = await TryResourceGet(resourceRef);
+                var source = await TryResourceGet(sourceRef);
                 if (source is null)
                 {
                     Logger.LogWarning("Could not update {id} - Source {sourceId} could not be found.",