ci: add retry to redis check

upstash · Nov 20, 2024 · b5c0212 · b5c0212
1 parent 35b441b
commit b5c0212
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/examples/ci/app/ci/ci.test.ts b/examples/ci/app/ci/ci.test.ts
@@ -10,7 +10,7 @@ describe("workflow integration tests", () => {
         await initiateTest(testConfig.route, testConfig.waitForSeconds)
       },
       {
-        timeout: (testConfig.waitForSeconds + 8) * 1000
+        timeout: (testConfig.waitForSeconds + 10) * 1000
       }
     )
   });

diff --git a/examples/ci/app/ci/upstash/redis.ts b/examples/ci/app/ci/upstash/redis.ts
@@ -87,7 +87,16 @@ export const checkRedisForResults = async (
   expectedResult: string,
 ) => {
   const key = getRedisKey("result", route, randomTestId)
-  const testResult = await redis.get<RedisResult>(key)
+  let testResult: RedisResult | null = null
+
+  for (let i=0; i<3; i++) {
+    testResult = await redis.get<RedisResult>(key)
+    if (testResult) {
+      break
+    }
+    await new Promise(r => setTimeout(r, 2000));
+  }
+
   if (!testResult) {
     throw new Error(`result not found for route ${route} with randomTestId ${randomTestId}`)
   }