Image monitor (cont.) (#172)

ibm-functions · May 8, 2024 · 56c6244 · 56c6244
1 parent bd1a382
commit 56c6244
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/invoker/src/main/scala/org/apache/openwhisk/core/invoker/ImageMonitor.scala b/core/invoker/src/main/scala/org/apache/openwhisk/core/invoker/ImageMonitor.scala
@@ -302,7 +302,8 @@ class ImageMonitor(cluster: String,
           if (build != docbuild || ip != docip || pod != docpod) {
             // write doc to image store to update metadata (eg invoker ip) if changed. after a new deployment
             // zookeeper persistent store is deleted and each invoker will most likely get a new identity (ip)
-            imageStore.putDoc(id, rev, toJson(images)).flatMap {
+            // filter out outdates images on sync with image store
+            imageStore.putDoc(id, rev, toJson(images, true)).flatMap {
               case Right(res) if (ip != docip || build != docbuild) =>
                 waitForEntriesToAppearInView(images.size).flatMap {
                   case count =>