READONLYやタイムアウトの場合リトライするように、それ以外のエラーはreconnectするように

MisskeyIO · Jan 2, 2024 · 7d8348b · 7d8348b
1 parent 9de26a4
commit 7d8348b
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/packages/backend/src/queue/const.ts b/packages/backend/src/queue/const.ts
@@ -25,6 +25,13 @@ export function baseQueueOptions(config: RedisOptions & RedisOptionsSource, queu
 			...config,
 			maxRetriesPerRequest: null,
 			keyPrefix: undefined,
+			reconnectOnError: (err: Error) => {
+				if ( err.message.includes('READONLY')
+					|| err.message.includes('ETIMEDOUT')
+					|| err.message.includes('Command timed out')
+				) return 2;
+				return 1;
+			}
 		},
 		prefix: config.prefix ? `${config.prefix}:queue:${queueName}` : `queue:${queueName}`,
 	};
@@ -37,6 +44,13 @@ export function baseWorkerOptions(config: RedisOptions & RedisOptionsSource, wor
 			...config,
 			maxRetriesPerRequest: null,
 			keyPrefix: undefined,
+			reconnectOnError: (err: Error) => {
+				if ( err.message.includes('READONLY')
+					|| err.message.includes('ETIMEDOUT')
+					|| err.message.includes('Command timed out')
+				) return 2;
+				return 1;
+			}
 		},
 		prefix: config.prefix ? `${config.prefix}:queue:${queueName}` : `queue:${queueName}`,
 	};