diff --git a/apps/api/src/app.ts b/apps/api/src/app.ts
index f043268..76f1137 100644
--- a/apps/api/src/app.ts
+++ b/apps/api/src/app.ts
@@ -55,6 +55,7 @@ import {
   pipedreamConfigFromEnv,
   piSessionsRoot,
   pushTokenPath,
+  GraphileJobWorkerHost,
   reconcileCloudAgents,
   reconcileComputerUpdates,
   removePiUserSessions,
@@ -427,6 +428,12 @@ export async function createApp(
   });
   if (inMemoryJobs) {
     await inMemoryJobs.start(jobHandlers);
+  } else if (jobPool) {
+    const graphileWorkerHost = new GraphileJobWorkerHost(jobPool, {
+      concurrency: 4,
+      pollInterval: 500,
+    });
+    await graphileWorkerHost.start(jobHandlers);
   }
   const reconciler = inMemoryJobs
     ? createJobReconciler({