From 91804d05c6a68a672e79bd184bcb99bdd543177b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= Date: Sat, 20 May 2023 22:26:40 +0200 Subject: [PATCH] fix(jdbc): use the executionId from the runContext for all triggers (#127) --- .../main/java/io/kestra/plugin/jdbc/AbstractJdbcTrigger.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/plugin-jdbc/src/main/java/io/kestra/plugin/jdbc/AbstractJdbcTrigger.java b/plugin-jdbc/src/main/java/io/kestra/plugin/jdbc/AbstractJdbcTrigger.java index b901a858..daf10acb 100644 --- a/plugin-jdbc/src/main/java/io/kestra/plugin/jdbc/AbstractJdbcTrigger.java +++ b/plugin-jdbc/src/main/java/io/kestra/plugin/jdbc/AbstractJdbcTrigger.java @@ -67,15 +67,13 @@ public Optional 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())