Make parentExecutionId available to BeforeTask methods

cppwfs · Dec 18, 2023 · 7cd9863 · 7cd9863
1 parent a2dca50
commit 7cd9863
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...ask-core/src/main/java/org/springframework/cloud/task/listener/TaskLifecycleListener.java b/...ask-core/src/main/java/org/springframework/cloud/task/listener/TaskLifecycleListener.java
@@ -391,7 +391,7 @@ private TaskExecution getTaskExecutionCopy(TaskExecution taskExecution) {
 		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/...ore/src/main/java/org/springframework/cloud/task/repository/dao/JdbcTaskExecutionDao.java b/...ore/src/main/java/org/springframework/cloud/task/repository/dao/JdbcTaskExecutionDao.java
@@ -219,7 +219,7 @@ public TaskExecution createTaskExecution(String taskName, LocalDateTime startTim
 		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)