Add assertion for making sure inference runs last

carlosdelest · Oct 26, 2023 · 7862cd1 · 7862cd1
1 parent 8ae3cc5
commit 7862cd1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java b/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java
@@ -159,6 +159,9 @@ public TransportBulkAction(
         this.indexingPressure = indexingPressure;
         this.systemIndices = systemIndices;
         clusterService.addStateApplier(this.ingestForwarder);
+
+        assert bulkRequestPreprocessors.get(bulkRequestPreprocessors.size() - 1) instanceof FieldInferenceBulkRequestPreprocessor
+            : "Last bulk request processor should be the inference processor";
     }
 
     /**