From d4108e3fac32c7db27502e5b00afea7caf310f8c Mon Sep 17 00:00:00 2001
From: Steven Zou <szou@vmware.com>
Date: Fri, 28 Aug 2020 17:55:36 +0800
Subject: [PATCH] fix(preheat):handle fail case of preheat in job

Signed-off-by: Steven Zou <szou@vmware.com>
---
 src/pkg/p2p/preheat/job.go | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/pkg/p2p/preheat/job.go b/src/pkg/p2p/preheat/job.go
index c11a87d9f..7321260b1 100644
--- a/src/pkg/p2p/preheat/job.go
+++ b/src/pkg/p2p/preheat/job.go
@@ -185,9 +185,15 @@ func (j *Job) Run(ctx job.Context, params job.Parameters) error {
 
 			myLogger.Infof("Check preheat progress: %s", s)
 
-			// Finished
-			if s.Status == provider.PreheatingStatusSuccess {
+			switch s.Status {
+			case provider.PreheatingStatusFail:
+				// Fail
+				return preheatJobRunningError(errors.Errorf("preheat failed: %s", s))
+			case provider.PreheatingStatusSuccess:
+				// Finished
 				return nil
+			default:
+				// do nothing, check again
 			}
 
 			if shouldStop() {