fix: pass the condition context to the trigger service

kestra-io · Jun 26, 2024 · cb6da81 · cb6da81
1 parent 970a25f
commit cb6da81
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/kestra/plugin/aws/sqs/RealtimeTrigger.java b/src/main/java/io/kestra/plugin/aws/sqs/RealtimeTrigger.java
@@ -113,7 +113,7 @@ public Publisher<Execution> evaluate(ConditionContext conditionContext, TriggerC
             .build();
 
         return Flux.from(publisher(task, conditionContext.getRunContext()))
-            .map(record -> TriggerService.generateRealtimeExecution(this, context, record));
+            .map(record -> TriggerService.generateRealtimeExecution(this, conditionContext, context, record));
     }
 
     public Flux<Message> publisher(final Consume task,