diff --git a/test/integration/aggregate.test.ts b/test/integration/aggregate.test.ts index 0751b9a3d..8eae38981 100644 --- a/test/integration/aggregate.test.ts +++ b/test/integration/aggregate.test.ts @@ -364,14 +364,8 @@ async function waitForSearchIndexing(): Promise { return; } } catch (error) { - if (isHttpError(error) && String(error.status).startsWith('5')) { - throw error; - } + // do nothing } await new Promise((resolve) => setTimeout(resolve, 2000)); return waitForSearchIndexing(); } - -function isHttpError(error: any): error is Error & { status?: number } { - return typeof error === 'object' && typeof error.status === 'number'; -} diff --git a/test/integration/search.test.ts b/test/integration/search.test.ts index 8d82d09e3..96e90eaa7 100644 --- a/test/integration/search.test.ts +++ b/test/integration/search.test.ts @@ -268,14 +268,8 @@ async function waitForSearchIndexing(): Promise { return; } } catch (error) { - if (isHttpError(error) && String(error.status).startsWith('5')) { - throw error; - } + // do nothing } await new Promise((resolve) => setTimeout(resolve, 2000)); return waitForSearchIndexing(); } - -function isHttpError(error: any): error is Error & { status?: number } { - return typeof error === 'object' && typeof error.status === 'number'; -} diff --git a/test/integration/vectorSearch.test.ts b/test/integration/vectorSearch.test.ts index 3eae9885e..77bc23ed2 100644 --- a/test/integration/vectorSearch.test.ts +++ b/test/integration/vectorSearch.test.ts @@ -118,14 +118,8 @@ async function waitForSearchIndexing(): Promise { return; } } catch (error) { - if (isHttpError(error) && String(error.status).startsWith('5')) { - throw error; - } + // do nothing } await new Promise((resolve) => setTimeout(resolve, 2000)); return waitForSearchIndexing(); } - -function isHttpError(error: any): error is Error & { status?: number } { - return typeof error === 'object' && typeof error.status === 'number'; -}