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)