chore: retryCondition now handles AlreadyExists.

appthrust · Jun 21, 2024 · 8b84e65 · 8b84e65
1 parent f85e2df
commit 8b84e65
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/packages/kubekit-client/package.json b/packages/kubekit-client/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@kubekit/client",
-  "version": "0.2.21",
+  "version": "0.2.23",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
   "author": "kahirokunn",

diff --git a/packages/kubekit-client/src/client/index.ts b/packages/kubekit-client/src/client/index.ts
@@ -3,7 +3,7 @@ import { Agent } from 'undici';
 import { ReadableStream, TransformStream } from 'node:stream/web';
 import { type ObjectReference } from '../lib/types';
 import { KubeConfig } from '../lib/config';
-import { KubernetesError, isKubernetesError, isTooLargeResourceVersion } from '../lib/error';
+import { KubernetesError, isAlreadyExists, isKubernetesError, isTooLargeResourceVersion } from '../lib/error';
 import { sleep } from '../lib/sleep';
 export { sleep } from '../lib/sleep';
 export { TaskManager } from '../lib/task_manager';
@@ -153,7 +153,7 @@ export const defaultRetryCondition: RetryConditionFunction = ({ ...object }) =>
     return false;
   }
 
-  if (isKubernetesError(error) && isTooLargeResourceVersion(error)) {
+  if (isKubernetesError(error) && (isTooLargeResourceVersion(error) || isAlreadyExists(error))) {
     return false;
   }
 

diff --git a/packages/kubekit-client/src/lib/error.ts b/packages/kubekit-client/src/lib/error.ts
@@ -81,3 +81,7 @@ export function isKubernetesError(obj: unknown): obj is KubernetesError {
 export function isTooLargeResourceVersion(err: KubernetesError) {
   return err.message.includes('Too large resource version');
 }
+
+export function isAlreadyExists(err: KubernetesError) {
+  return err.reason === 'AlreadyExists';
+}