fix: pass the condition context to the trigger service

kestra-io · Jun 27, 2024 · af013fe · af013fe
1 parent c7aabab
commit af013fe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/kestra/plugin/azure/eventhubs/RealtimeTrigger.java b/src/main/java/io/kestra/plugin/azure/eventhubs/RealtimeTrigger.java
@@ -142,7 +142,7 @@ public Publisher<Execution> evaluate(ConditionContext conditionContext, TriggerC
             .build();
         return Flux
             .from(publisher(task, conditionContext.getRunContext()))
-            .map(event -> TriggerService.generateRealtimeExecution(this, context, event));
+            .map(event -> TriggerService.generateRealtimeExecution(this, conditionContext, context, event));
     }
 
     public Publisher<EventDataOutput> publisher(final Consume task,