diff --git a/src/ES.Kubernetes.Reflector/Core/Mirroring/ResourceMirror.cs b/src/ES.Kubernetes.Reflector/Core/Mirroring/ResourceMirror.cs
index 1cdeaa6..2f1d219 100644
--- 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.",