diff --git a/x-pack/plugins/transform/server/routes/api/transforms.ts b/x-pack/plugins/transform/server/routes/api/transforms.ts index 7c4df878456bae..580f0f54aabf7f 100644 --- a/x-pack/plugins/transform/server/routes/api/transforms.ts +++ b/x-pack/plugins/transform/server/routes/api/transforms.ts @@ -155,10 +155,13 @@ export function registerTransformsRoutes(routeDependencies: RouteDependencies) { async (ctx, req, res) => { try { const esClient = (await ctx.core).elasticsearch.client; - const body = await esClient.asCurrentUser.transform.getTransformStats({ - size: 1000, - transform_id: '_all', - }); + const body = await esClient.asCurrentUser.transform.getTransformStats( + { + size: 1000, + transform_id: '_all', + }, + { maxRetries: 0 } + ); return res.ok({ body }); } catch (e) { return res.customError(wrapError(wrapEsError(e))); @@ -185,9 +188,12 @@ export function registerTransformsRoutes(routeDependencies: RouteDependencies) { const { transformId } = req.params; try { const esClient = (await ctx.core).elasticsearch.client; - const body = await esClient.asCurrentUser.transform.getTransformStats({ - transform_id: transformId, - }); + const body = await esClient.asCurrentUser.transform.getTransformStats( + { + transform_id: transformId, + }, + { maxRetries: 0 } + ); return res.ok({ body }); } catch (e) { return res.customError(wrapError(wrapEsError(e))); @@ -452,7 +458,7 @@ export function registerTransformsRoutes(routeDependencies: RouteDependencies) { license.guardApiRoute(async (ctx, req, res) => { try { const esClient = (await ctx.core).elasticsearch.client; - const body = await esClient.asCurrentUser.search(req.body); + const body = await esClient.asCurrentUser.search(req.body, { maxRetries: 0 }); return res.ok({ body }); } catch (e) { return res.customError(wrapError(wrapEsError(e))); @@ -643,16 +649,22 @@ const previewTransformHandler: RequestHandler< try { const reqBody = req.body; const esClient = (await ctx.core).elasticsearch.client; - const body = await esClient.asCurrentUser.transform.previewTransform({ - body: reqBody, - }); + const body = await esClient.asCurrentUser.transform.previewTransform( + { + body: reqBody, + }, + { maxRetries: 0 } + ); if (isLatestTransform(reqBody)) { // for the latest transform mappings properties have to be retrieved from the source - const fieldCapsResponse = await esClient.asCurrentUser.fieldCaps({ - index: reqBody.source.index, - fields: '*', - include_unmapped: false, - }); + const fieldCapsResponse = await esClient.asCurrentUser.fieldCaps( + { + index: reqBody.source.index, + fields: '*', + include_unmapped: false, + }, + { maxRetries: 0 } + ); const fieldNamesSet = new Set(Object.keys(fieldCapsResponse.fields));