From 6cf9a7432e611a42e22c6a8a8105b6cd4090d8d7 Mon Sep 17 00:00:00 2001 From: Viren Baraiya Date: Tue, 6 Dec 2022 14:47:08 -0800 Subject: [PATCH 1/2] call execute in case JQ execution failed to start --- .../com/netflix/conductor/tasks/json/JsonJqTransform.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java b/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java index 5bd28b0f39..22d0bb4ba1 100644 --- a/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java +++ b/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java @@ -112,6 +112,12 @@ private LoadingCache createQueryCache() { .build(loader); } + @Override + public boolean execute(WorkflowModel workflow, TaskModel task, WorkflowExecutor workflowExecutor) { + this.start(workflow, task, workflowExecutor); + return true; + } + private String extractFirstValidMessage(final Exception e) { Throwable currentStack = e; final List messages = new ArrayList<>(); From ca18e9436c17c10f110bc69c6d49d81135d7e0bf Mon Sep 17 00:00:00 2001 From: Viren Baraiya Date: Fri, 3 Mar 2023 12:41:35 -0800 Subject: [PATCH 2/2] update formatting --- .../java/com/netflix/conductor/tasks/json/JsonJqTransform.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java b/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java index 22d0bb4ba1..0cbed1c5dd 100644 --- a/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java +++ b/json-jq-task/src/main/java/com/netflix/conductor/tasks/json/JsonJqTransform.java @@ -113,7 +113,8 @@ private LoadingCache createQueryCache() { } @Override - public boolean execute(WorkflowModel workflow, TaskModel task, WorkflowExecutor workflowExecutor) { + public boolean execute( + WorkflowModel workflow, TaskModel task, WorkflowExecutor workflowExecutor) { this.start(workflow, task, workflowExecutor); return true; }