diff --git a/vars/workers.groovy b/vars/workers.groovy
index b6ff5b27667dd..a1d569595ab4b 100644
--- a/vars/workers.groovy
+++ b/vars/workers.groovy
@@ -9,6 +9,8 @@ def label(size) {
       return 'docker && linux && immutable'
     case 's-highmem':
       return 'docker && tests-s'
+    case 'm-highmem':
+      return 'docker && linux && immutable && gobld/machineType:n1-highmem-8'
     case 'l':
       return 'docker && tests-l'
     case 'xl':
@@ -132,7 +134,7 @@ def ci(Map params, Closure closure) {
 // Worker for running the current intake jobs. Just runs a single script after bootstrap.
 def intake(jobName, String script) {
   return {
-    ci(name: jobName, size: 's-highmem', ramDisk: true) {
+    ci(name: jobName, size: 'm-highmem', ramDisk: true) {
       withEnv(["JOB=${jobName}"]) {
         kibanaPipeline.notifyOnError {
           runbld(script, "Execute ${jobName}")