diff --git a/x-pack/plugins/task_manager/server/task_manager.ts b/x-pack/plugins/task_manager/server/task_manager.ts index 2c812f0da516d..6fb182139cb2a 100644 --- a/x-pack/plugins/task_manager/server/task_manager.ts +++ b/x-pack/plugins/task_manager/server/task_manager.ts @@ -395,7 +395,7 @@ export async function claimAvailableTasks( try { const { docs, claimedTasks } = await claim({ - size: availableWorkers, + size: availableWorkers * 2, // get more than we have capacity for claimOwnershipUntil: intervalFromNow('30s')!, claimTasksById, });