sdi-1177 make consistent behavior for RecordFailure

intelsdi-x · May 26, 2016 · 0433b6e · 0433b6e
1 parent c0a14c7
commit 0433b6e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/scheduler/workflow.go b/scheduler/workflow.go
@@ -318,8 +318,8 @@ func (s *schedulerWorkflow) Start(t *task) {
 	// Block until the job has been either run or skipped.
 	errors := t.manager.Work(j).Promise().Await()
 
-	if len(errors) != 0 {
-		t.RecordFailure(j.Errors())
+	if len(errors) > 0 {
+		t.RecordFailure(errors)
 		event := new(scheduler_event.MetricCollectionFailedEvent)
 		event.TaskID = t.id
 		event.Errors = errors