fix: allow propagation time for async conditions

Signed-off-by: Justin Alvarez <[email protected]>

tests/events.go

@@ -4,6 +4,8 @@
 package tests
 
 import (
+	"time"
+
 	"github.com/onsi/ginkgo/v2"
 	"github.com/onsi/gomega"
 
@@ -26,7 +28,11 @@ func Events(o *option.Option) {
 			defer session.Kill()
 			gomega.Expect(session.Out.Contents()).Should(gomega.BeEmpty())
 			command.Run(o, "pull", defaultImage)
-			gomega.Expect(session.Out.Contents()).Should(gomega.ContainSubstring(defaultImage))
+			// allow propagation time
+			gomega.Eventually(session.Out.Contents()).
+				WithTimeout(15 * time.Second).
+				WithPolling(1 * time.Second).
+				Should(gomega.ContainSubstring(defaultImage))
 		})
 	})
 }

tests/logs.go

@@ -100,7 +100,11 @@ func Logs(o *option.Option) {
 					gomega.Expect(session.Out.Contents()).Should(gomega.BeEmpty())
 					command.Run(o, "exec", testContainerName, "sh", "-c", fmt.Sprintf("echo %s >> /proc/1/fd/1", newLog))
 					output := strings.TrimSpace(string(session.Out.Contents()))
-					gomega.Expect(output).Should(gomega.Equal(newLog))
+					// allow propagation time
+					gomega.Eventually(output).
+						WithTimeout(15 * time.Second).
+						WithPolling(1 * time.Second).
+						Should(gomega.Equal(newLog))
 				})
 			}
 		})