test: memorydb failover settings

kevinkim-ogp · kevinkim-ogp · commit 0b7f3ec05997 · 2025-07-28T18:55:40.000+08:00
diff --git a/packages/backend/src/config/redis.ts b/packages/backend/src/config/redis.ts
@@ -19,7 +19,7 @@ function reconnectOnError(err: Error) {
   if (err.message.includes(targetError)) {
     // Only reconnect when the error contains "READONLY"
     // during node failover, this is thrown: 149: -READONLY You can't write against a read only replica.
-    return true
+    return 2 // TEST: ioredis resend the failed command after reconnecting
   }
   return false
 }
@@ -35,6 +35,10 @@ export const createRedisClient = (db = REDIS_DB_INDEX.JOBS) =>
         ],
         {
           dnsLookup: (address, callback) => callback(null, address),
+
+          // TEST: Handle individual node failovers during MemoryDB updates
+          retryDelayOnFailover: 100,
+
           redisOptions: {
             tls: appConfig.redisTls ? {} : undefined,
             username: appConfig.redisUsername,

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,7 @@ function reconnectOnError(err: Error) {`
`19`	`19`	`if (err.message.includes(targetError)) {`
`20`	`20`	`// Only reconnect when the error contains "READONLY"`
`21`	`21`	`// during node failover, this is thrown: 149: -READONLY You can't write against a read only replica.`
`22`		`- return true`
	`22`	`+ return 2 // TEST: ioredis resend the failed command after reconnecting`
`23`	`23`	`}`
`24`	`24`	`return false`
`25`	`25`	`}`
`@@ -35,6 +35,10 @@ export const createRedisClient = (db = REDIS_DB_INDEX.JOBS) =>`
`35`	`35`	`],`
`36`	`36`	`{`
`37`	`37`	`dnsLookup: (address, callback) => callback(null, address),`
	`38`	`+`
	`39`	`+ // TEST: Handle individual node failovers during MemoryDB updates`
	`40`	`+ retryDelayOnFailover: 100,`
	`41`	`+`
`38`	`42`	`redisOptions: {`
`39`	`43`	`tls: appConfig.redisTls ? {} : undefined,`
`40`	`44`	`username: appConfig.redisUsername,`