diff --git a/SingularityService/src/main/java/com/hubspot/singularity/data/TaskManager.java b/SingularityService/src/main/java/com/hubspot/singularity/data/TaskManager.java index ff67d771b6..e72c37718a 100644 --- a/SingularityService/src/main/java/com/hubspot/singularity/data/TaskManager.java +++ b/SingularityService/src/main/java/com/hubspot/singularity/data/TaskManager.java @@ -564,7 +564,13 @@ private void createTaskAndDeletePendingTaskPrivate(SingularityTask task) throws final long now = System.currentTimeMillis(); - saveTaskHistoryUpdate(new SingularityTaskHistoryUpdate(task.getTaskId(), now, ExtendedTaskState.TASK_LAUNCHED, Optional.absent())); + String msg = String.format("Task launched because of pending type %s", task.getTaskRequest().getPendingTask().getPendingTaskId().getPendingType().name()); + + if (task.getTaskRequest().getPendingTask().getUser().isPresent()) { + msg = msg + " by " + task.getTaskRequest().getPendingTask().getUser().get(); + } + + saveTaskHistoryUpdate(new SingularityTaskHistoryUpdate(task.getTaskId(), now, ExtendedTaskState.TASK_LAUNCHED, Optional.of(msg))); saveLastActiveTaskStatus(new SingularityTaskStatusHolder(task.getTaskId(), Optional.absent(), now, serverId, Optional.of(task.getOffer().getSlaveId().getValue()))); try {