From af013fe4173d974baf21cf4e4a8af92a7db3427a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= <loikeseke@gmail.com>
Date: Tue, 25 Jun 2024 17:19:44 +0200
Subject: [PATCH] fix: pass the condition context to the trigger service

---
 .../java/io/kestra/plugin/azure/eventhubs/RealtimeTrigger.java  | 2 +-
 1 file changed, 1 insertion(+), 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
index 0b164d3..9520b28 100644
--- 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,