Improve status conditions

Author: 0x2b3bfa0

iterative/utils/logger.go

@@ -72,13 +72,13 @@ func (f *tpiFormatter) Format(entry *logrus.Entry) ([]byte, error) {
 
 		message = fmt.Sprintf("\x1b[%dmStatus: queued 🔵\x1b[0m", colors["DEBUG"])
 
-		if status["succeeded"] != nil && status["succeeded"].(int) > 0 {
+		if status["succeeded"] != nil && status["succeeded"].(int) >= d.Get("parallelism").(int) {
 			message = fmt.Sprintf("\x1b[%dmStatus: completed succesfully 🟢\x1b[0m", colors["SUCCESS"])
 		}
 		if status["failed"] != nil && status["failed"].(int) > 0 {
 			message = fmt.Sprintf("\x1b[%dmStatus: completed with errors 🔴\x1b[0m", colors["ERROR"])
 		}
-		if status["running"] != nil && status["running"].(int) > 0 {
+		if status["running"] != nil && status["running"].(int) >= d.Get("parallelism").(int) {
 			message = fmt.Sprintf("\x1b[%dmStatus: running 🟡\x1b[0m", colors["WARNING"])
 		}
 	}

iterative/utils/logger_test.go

@@ -9,6 +9,7 @@ import (
 func TestState(t *testing.T) {
 	d := generateSchemaData(t, map[string]interface{}{
 		"name": "mytask",
+		"parallelism": "1",
 		"status": map[string]interface{}{
 			"running": 0,
 			"failed":  0,
@@ -22,6 +23,7 @@ func TestState(t *testing.T) {
 func TestState2(t *testing.T) {
 	d := generateSchemaData(t, map[string]interface{}{
 		"name": "mytask",
+		"parallelism": "1",
 		"status": map[string]interface{}{
 			"running": 0,
 			"failed":  1,
@@ -35,6 +37,7 @@ func TestState2(t *testing.T) {
 func TestState3(t *testing.T) {
 	d := generateSchemaData(t, map[string]interface{}{
 		"name": "mytask",
+		"parallelism": "1",
 		"status": map[string]interface{}{
 			"running":   0,
 			"succeeded": 1,
@@ -141,6 +144,12 @@ func generateSchemaData(t *testing.T, raw map[string]interface{}) *schema.Resour
 				Type: schema.TypeString,
 			},
 		},
+		"parallelism": {
+			Type:     schema.TypeInt,
+			ForceNew: true,
+			Optional: true,
+			Default:  1,
+		},
 		"script": {
 			Type:     schema.TypeString,
 			ForceNew: true,