payer fsp fix (#102)

openMF · Mar 13, 2024 · 3820de2 · 3820de2
1 parent 5cc9979
commit 3820de2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);
                 }