support Tekton PipelineRunStopping status

kubeflow · Apr 15, 2021 · 02a97e6 · 02a97e6
1 parent 7dd6e00
commit 02a97e6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/backend/src/apiserver/storage/run_store.go b/backend/src/apiserver/storage/run_store.go
@@ -605,8 +605,8 @@ func (s *RunStore) TerminateRun(runId string) error {
 	result, err := s.db.Exec(`
 		UPDATE run_details
 		SET Conditions = ?
-		WHERE UUID = ? AND (Conditions = ? OR Conditions = ? OR Conditions = ?)`,
-		model.RunTerminatingConditions, runId, string("Running"), string("Pending"), "")
+		WHERE UUID = ? AND (Conditions = ? OR Conditions = ? OR Conditions = ? OR Conditions = ?)`,
+		model.RunTerminatingConditions, runId, string("Running"), string("Pending"), "", string("PipelineRunStopping"))
 
 	if err != nil {
 		return util.NewInternalServerError(err,

diff --git a/frontend/src/lib/StatusUtils.ts b/frontend/src/lib/StatusUtils.ts
@@ -42,6 +42,7 @@ export enum NodePhase {
   CONDITIONCHECKFAILED = 'ConditionCheckFailed',
   PIPELINERUNCANCELLED = 'PipelineRunCancelled',
   PIPELINERUNCOULDNTCANCEL = 'PipelineRunCouldntCancel',
+  PIPELINERUNSTOPPING = 'PipelineRunStopping',
   TASKRUNCANCELLED = 'TaskRunCancelled',
   TASKRUNCOULDNTCANCEL = 'TaskRunCouldntCancel',
   TERMINATED = 'Terminated',
@@ -131,6 +132,7 @@ export function statusToPhase(nodeStatus: string | undefined): NodePhase {
   else if (nodeStatus === 'Completed') return 'Succeeded' as NodePhase;
   else if (nodeStatus === 'ConditionCheckFailed') return 'Skipped' as NodePhase;
   else if (nodeStatus === 'CouldntGetCondition') return 'Error' as NodePhase;
+  else if (nodeStatus === 'PipelineRunStopping') return 'Running' as NodePhase;
   else if (
     nodeStatus === 'PipelineRunCancelled' ||
     nodeStatus === 'PipelineRunCouldntCancel' ||