Skip to content

Commit 7cd9863

Browse files
committed
Make parentExecutionId available to BeforeTask methods
1 parent a2dca50 commit 7cd9863

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

spring-cloud-task-core/src/main/java/org/springframework/cloud/task/listener/TaskLifecycleListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -391,7 +391,7 @@ private TaskExecution getTaskExecutionCopy(TaskExecution taskExecution) {
391391
return new TaskExecution(taskExecution.getExecutionId(), taskExecution.getExitCode(),
392392
taskExecution.getTaskName(), startTime, endTime, taskExecution.getExitMessage(),
393393
Collections.unmodifiableList(taskExecution.getArguments()), taskExecution.getErrorMessage(),
394-
taskExecution.getExternalExecutionId());
394+
taskExecution.getExternalExecutionId(), taskExecution.getParentExecutionId());
395395
}
396396

397397
@Override

spring-cloud-task-core/src/main/java/org/springframework/cloud/task/repository/dao/JdbcTaskExecutionDao.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ public TaskExecution createTaskExecution(String taskName, LocalDateTime startTim
219219
long nextExecutionId = getNextExecutionId();
220220

221221
TaskExecution taskExecution = new TaskExecution(nextExecutionId, null, taskName, startTime, null, null,
222-
arguments, null, externalExecutionId);
222+
arguments, null, externalExecutionId, parentExecutionId);
223223

224224
final MapSqlParameterSource queryParameters = new MapSqlParameterSource()
225225
.addValue("taskExecutionId", nextExecutionId, Types.BIGINT)

0 commit comments

Comments
 (0)