New statuses for job instance: Submitting and SubmissionTimeout (#414)

* #333 New statuses for job instance: Submitting and SubmissionTimeout

Author: jozefbakus

src/main/scala/za/co/absa/hyperdrive/trigger/models/enums/JobStatuses.scala

@@ -28,11 +28,12 @@ object JobStatuses {
   case object Succeeded extends JobStatus("Succeeded", true, false, false)
   case object Failed extends JobStatus("Failed", true, true, false)
   case object Killed extends JobStatus("Killed", true, true, false)
+  case object SubmissionTimeout extends JobStatus("Submission timeout", true, true, false)
   case object InvalidExecutor extends JobStatus("InvalidExecutor", true, true, false)
   case object FailedPreviousJob extends JobStatus("FailedPreviousJob", true, true, false)
   case object Skipped extends JobStatus("Skipped", true, false, false)
 
-  val statuses: Set[JobStatus] = Set(InQueue,Submitting,Running,Lost,Succeeded,Failed,Killed,InvalidExecutor,FailedPreviousJob,Skipped)
+  val statuses: Set[JobStatus] = Set(InQueue,Submitting,Running,Lost,Succeeded,Failed,Killed,SubmissionTimeout,InvalidExecutor,FailedPreviousJob,Skipped)
   val finalStatuses: Set[JobStatus] = statuses.filter(!_.isFinalStatus)
   val nonFinalStatuses: Set[JobStatus] = statuses.filter(_.isFinalStatus)
 }

src/main/scala/za/co/absa/hyperdrive/trigger/scheduler/executors/spark/SparkExecutor.scala

@@ -65,6 +65,7 @@ object SparkExecutor extends Executor {
         case None => Seq.empty
       }) match {
         case Seq(first) => updateJob(jobInstance.copy(jobStatus = getStatus(first.finalStatus)))
+        case _ if jobInstance.jobStatus == Submitting => updateJob(jobInstance.copy(jobStatus = SubmissionTimeout))
         case _ => updateJob(jobInstance.copy(jobStatus = Lost))
       }
     }

ui/src/app/components/runs/run-detail/run-detail.component.html

@@ -29,10 +29,12 @@
       <clr-dg-cell>{{jobInstance.updated | date:'medium'}}</clr-dg-cell>
       <clr-dg-cell [ngSwitch]="jobInstance.jobStatus.name">
         <clr-icon *ngSwitchCase="jobStatuses.IN_QUEUE" shape="clock" class="is-solid" style="color: darkmagenta"></clr-icon>
+        <clr-icon *ngSwitchCase="jobStatuses.SUBMITTING" shape="upload" class="is-solid" style="color: cornflowerblue"></clr-icon>
         <clr-icon *ngSwitchCase="jobStatuses.RUNNING" shape="play" class="is-solid" style="color: blue"></clr-icon>
         <clr-icon *ngSwitchCase="jobStatuses.SUCCEEDED" shape="success-standard" class="is-solid" style="color: green"></clr-icon>
         <clr-icon *ngSwitchCase="jobStatuses.FAILED" shape="error-standard" class="is-solid" style="color: red"></clr-icon>
         <clr-icon *ngSwitchCase="jobStatuses.SKIPPED" shape="fast-forward" class="is-solid" style="color: grey"></clr-icon>
+        <clr-icon *ngSwitchCase="jobStatuses.SUBMISSION_TIMEOUT" shape="clock" class="has-badge is-solid" style="color: orangered"></clr-icon>
         <clr-icon *ngSwitchDefault shape="help" class="is-solid" style="color: darkgoldenrod"></clr-icon>
         {{jobInstance.jobStatus.name}}
       </clr-dg-cell>

ui/src/app/models/enums/jobStatuses.constants.ts

@@ -15,8 +15,10 @@
 
 export const jobStatuses = {
   IN_QUEUE: 'InQueue',
+  SUBMITTING: 'Submitting',
   RUNNING: 'Running',
   SUCCEEDED: 'Succeeded',
   FAILED: 'Failed',
   SKIPPED: 'Skipped',
+  SUBMISSION_TIMEOUT: 'Submission timeout',
 };