fix(Consume): reflect core changes

kestra-io · Aug 5, 2024 · 380fec5 · 380fec5
1 parent 4f64bf3
commit 380fec5
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/build.gradle b/build.gradle
@@ -91,7 +91,7 @@ dependencies {
     // test deps needed only for to have a runner
     testAnnotationProcessor group: "io.kestra", name: "processor", version: kestraVersion
     testImplementation group: "io.kestra", name: "core", version: kestraVersion
-    testImplementation group: "io.kestra", name: "core", version: kestraVersion, classifier: "tests"
+    testImplementation group: "io.kestra", name: "tests", version: kestraVersion
     testImplementation group: "io.kestra", name: "repository-memory", version: kestraVersion
     testImplementation group: "io.kestra", name: "runner-memory", version: kestraVersion
     testImplementation group: "io.kestra", name: "storage-local", version: kestraVersion

diff --git a/src/main/java/io/kestra/plugin/solace/Consume.java b/src/main/java/io/kestra/plugin/solace/Consume.java
@@ -96,7 +96,7 @@ public Output run(RunContext runContext) throws Exception {
 
     Output run(RunContext runContext, SolaceConsumeInterface task) throws Exception {
 
-        File tempFile = runContext.tempFile(".ion").toFile();
+        File tempFile = runContext.workingDir().createTempFile(".ion").toFile();
         try (
             BufferedOutputStream output = new BufferedOutputStream(new FileOutputStream(tempFile))
         ) {

diff --git a/src/main/java/io/kestra/plugin/solace/Trigger.java b/src/main/java/io/kestra/plugin/solace/Trigger.java
@@ -124,7 +124,7 @@ public Optional<Execution> evaluate(ConditionContext conditionContext,
             .id(runContext.getTriggerExecutionId())
             .namespace(context.getNamespace())
             .flowId(context.getFlowId())
-            .flowRevision(context.getFlowRevision())
+            .flowRevision(conditionContext.getFlow().getRevision())
             .state(new State())
             .trigger(executionTrigger)
             .build();