diff --git a/src/main/java/hu/dpc/phee/operator/streams/RecordParser.java b/src/main/java/hu/dpc/phee/operator/streams/RecordParser.java
index b0053ab2..198fdfc4 100644
--- a/src/main/java/hu/dpc/phee/operator/streams/RecordParser.java
+++ b/src/main/java/hu/dpc/phee/operator/streams/RecordParser.java
@@ -135,7 +135,7 @@ public List<Object> processWorkflowInstance(DocumentContext recordDocument, Stri
                 logger.debug("found {} constant transformers for flow start {}", constantTransformers.size(), bpmn);
             } else if ("ELEMENT_COMPLETED".equals(intent)) {
                 logger.info("Inside ELEMENT_COMPLETED");
-                if (!config.get().getName().equalsIgnoreCase("bulk_processor")) {
+                if (!config.get().getName().contains("bulk_processor")) {
                     logger.info("Inside if condition PROCESS_INSTANCE, json {}", recordType);
                     inflightBatchManager.checkWorkerIdAndUpdateTransferData(batch, workflowInstanceKey, timestamp);
                 }