feat(webserver): allow triggering execution at a specified revision

kestra-io · Mar 7, 2023 · 6e6c333 · 6e6c333
1 parent 9c1c012
commit 6e6c333
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/webserver/src/main/java/io/kestra/webserver/controllers/ExecutionController.java b/webserver/src/main/java/io/kestra/webserver/controllers/ExecutionController.java
@@ -431,9 +431,10 @@ public Execution trigger(
         @Parameter(description = "The flow id") @PathVariable String id,
         @Parameter(description = "The inputs") @Nullable @Body Map<String, String> inputs,
         @Parameter(description = "The inputs of type file") @Nullable @Part Publisher<StreamingFileUpload> files,
-        @Parameter(description = "If the server will wait the end of the execution") @QueryValue(defaultValue = "false") Boolean wait
+        @Parameter(description = "If the server will wait the end of the execution") @QueryValue(defaultValue = "false") Boolean wait,
+        @Parameter(description = "The flow revision or latest if null") @QueryValue Optional<Integer> revision
     ) {
-        Optional<Flow> find = flowRepository.findById(namespace, id);
+        Optional<Flow> find = flowRepository.findById(namespace, id, revision);
         if (find.isEmpty()) {
             return null;
         }