diff --git a/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java b/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java
index edcc038a..08459b76 100644
--- a/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java
+++ b/code/libraries/blocking-thread-pool/src/main/java/nu/marginalia/util/ProcessingIterator.java
@@ -38,7 +38,7 @@ public class ProcessingIterator<T> implements Iterator<T> {
 
     private void executeJob(ProcessingJob<T> job) {
         try {
-            job.run(this::executeTask);
+            job.run(j -> executorService.submit(() -> executeTask(j)));
         } catch (Exception e) {
             logger.warn("Exception while processing", e);
         } finally {