fix(nats): use the executionId from the runContext for all triggers (#4)

kestra-io · May 20, 2023 · 1eef955 · 1eef955
1 parent 0739593
commit 1eef955
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/main/java/io/kestra/plugin/nats/Trigger.java b/src/main/java/io/kestra/plugin/nats/Trigger.java
@@ -95,15 +95,13 @@ public Optional<Execution> evaluate(ConditionContext conditionContext, TriggerCo
             return Optional.empty();
         }
 
-        String executionId = IdUtils.create();
-
         ExecutionTrigger executionTrigger = ExecutionTrigger.of(
             this,
             run
         );
 
         Execution execution = Execution.builder()
-            .id(executionId)
+            .id(runContext.getTriggerExecutionId())
             .namespace(context.getNamespace())
             .flowId(context.getFlowId())
             .flowRevision(context.getFlowRevision())