Add StartTime and CompletionTime in job status

.gitignore

@@ -1,2 +1,3 @@
 .idea/
+.vscode/
 vendor/

pkg/apis/kubeflow/v1alpha1/types.go

@@ -117,4 +117,14 @@ type MPIJobStatus struct {
 	// The number of available worker replicas.
 	// +optional
 	WorkerReplicas int32 `json:"workerReplicas,omitempty"`
+
+	// Represents time when the job was acknowledged by the job controller.
+	// It is not guaranteed to be set in happens-before order across separate operations.
+	// It is represented in RFC3339 form and is in UTC.
+	StartTime *metav1.Time `json:"startTime,omitempty"`
+
+	// Represents time when the job was completed. It is not guaranteed to
+	// be set in happens-before order across separate operations.
+	// It is represented in RFC3339 form and is in UTC.
+	CompletionTime *metav1.Time `json:"completionTime,omitempty"`
 }

pkg/controllers/mpi_job_controller.go

@@ -769,10 +769,17 @@ func (c *MPIJobController) updateMPIJobStatus(mpiJob *kubeflow.MPIJob, launcher
 	// Or create a copy manually for better performance
 	mpiJobCopy := mpiJob.DeepCopy()
 	if launcher != nil {
+		now := metav1.Now()
 		if launcher.Status.Active > 0 {
 			mpiJobCopy.Status.LauncherStatus = kubeflow.LauncherActive
+			if mpiJobCopy.Status.StartTime == nil {
+				mpiJobCopy.Status.StartTime = &now
+			}
 		} else if launcher.Status.Succeeded > 0 {
 			mpiJobCopy.Status.LauncherStatus = kubeflow.LauncherSucceeded
+			if mpiJobCopy.Status.CompletionTime == nil {
+				mpiJobCopy.Status.CompletionTime = &now
+			}
 		} else if launcher.Status.Failed > 0 {
 			mpiJobCopy.Status.LauncherStatus = kubeflow.LauncherFailed
 		}