Skip to content

Commit 625a46e

Browse files
authored
fix(couchbase): use the executionId from the runContext for all triggers (#5)
1 parent faae99f commit 625a46e

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

src/main/java/io/kestra/plugin/couchbase/Trigger.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -111,15 +111,13 @@ public Optional<Execution> evaluate(ConditionContext conditionContext, TriggerCo
111111
return Optional.empty();
112112
}
113113

114-
String executionId = IdUtils.create();
115-
116114
ExecutionTrigger executionTrigger = ExecutionTrigger.of(
117115
this,
118116
queryOutput
119117
);
120118

121119
Execution execution = Execution.builder()
122-
.id(executionId)
120+
.id(runContext.getTriggerExecutionId())
123121
.namespace(context.getNamespace())
124122
.flowId(context.getFlowId())
125123
.flowRevision(context.getFlowRevision())

0 commit comments

Comments
 (0)