address review

src/meta/processors/job/JobDescription.cpp

@@ -83,12 +83,16 @@ cpp2::JobDesc JobDescription::toJobDesc() {
   return ret;
 }
 
+bool JobDescription::canForceSetStatus(Status status) {
+  return status != cpp2::JobStatus::FINISHED;
+}
+
 bool JobDescription::setStatus(Status newStatus, bool force) {
-  if (status_ == cpp2::JobStatus::FINISHED) {
-    // no one should change the status of a finished job
-    // in case that recovered job running again, but set finished to finished should be ok
-    return newStatus == cpp2::JobStatus::FINISHED;
+  if (canForceSetStatus(status_)) {
+    // no need to change time.
+    return status_ == newStatus;
   }
+
   if (JobStatus::laterThan(status_, newStatus) && !force) {
     return false;
   }

src/meta/processors/job/JobDescription.h

@@ -170,6 +170,9 @@ class JobDescription {
     return !(*this == that);
   }
 
+ private:
+  bool canForceSetStatus(Status status);
+
  private:
   // Because all jobs are space-level, spaceName is not in paras_.
   GraphSpaceID space_;

src/meta/processors/job/JobManager.cpp

@@ -688,6 +688,7 @@ bool JobManager::isExpiredJob(JobDescription& jobDesc) {
   auto jobStart = jobDesc.getStartTime();
   if (jobStart == 0) {
     // should not happend, but just in case keep this job
+    LOG(INFO) << "Job " << jobDesc.getJobId() << " start time is not set, keep it for now";
     return false;
   }
   auto duration = std::difftime(nebula::time::WallClock::fastNowInSec(), jobStart);