From 7cd9863a51525a7dad592a4b49b82aeaaa842f2a Mon Sep 17 00:00:00 2001 From: Glenn Renfro Date: Mon, 18 Dec 2023 16:46:30 -0500 Subject: [PATCH] Make parentExecutionId available to BeforeTask methods --- .../cloud/task/listener/TaskLifecycleListener.java | 2 +- .../cloud/task/repository/dao/JdbcTaskExecutionDao.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/listener/TaskLifecycleListener.java b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/listener/TaskLifecycleListener.java index a24d8108..87a139c9 100644 --- a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/listener/TaskLifecycleListener.java +++ b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/listener/TaskLifecycleListener.java @@ -391,7 +391,7 @@ public class TaskLifecycleListener return new TaskExecution(taskExecution.getExecutionId(), taskExecution.getExitCode(), taskExecution.getTaskName(), startTime, endTime, taskExecution.getExitMessage(), Collections.unmodifiableList(taskExecution.getArguments()), taskExecution.getErrorMessage(), - taskExecution.getExternalExecutionId()); + taskExecution.getExternalExecutionId(), taskExecution.getParentExecutionId()); } @Override diff --git a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/repository/dao/JdbcTaskExecutionDao.java b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/repository/dao/JdbcTaskExecutionDao.java index c77b1afd..350e643f 100644 --- a/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/repository/dao/JdbcTaskExecutionDao.java +++ b/spring-cloud-task-core/src/main/java/org/springframework/cloud/task/repository/dao/JdbcTaskExecutionDao.java @@ -219,7 +219,7 @@ public class JdbcTaskExecutionDao implements TaskExecutionDao { long nextExecutionId = getNextExecutionId(); TaskExecution taskExecution = new TaskExecution(nextExecutionId, null, taskName, startTime, null, null, - arguments, null, externalExecutionId); + arguments, null, externalExecutionId, parentExecutionId); final MapSqlParameterSource queryParameters = new MapSqlParameterSource() .addValue("taskExecutionId", nextExecutionId, Types.BIGINT)