Add step filter to List-Steps API for long running EMR clusters

dsc133 · Sep 10, 2021 · 30591fd · 30591fd
1 parent 50dba1a
commit 30591fd
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/aws/resource_aws_emr_cluster.go b/aws/resource_aws_emr_cluster.go
@@ -1139,8 +1139,19 @@ func resourceAwsEMRClusterRead(d *schema.ResourceData, meta interface{}) error {
 	}
 
 	var stepSummaries []*emr.StepSummary
+	states := []string{
+		"PENDING",
+		"FAILED",
+		"CANCEL_PENDING",
+		"RUNNING",
+	}
+	var stepStates []*string
+	for _, v := range states {
+		stepStates = append(stepStates, &v)
+	}
 	listStepsInput := &emr.ListStepsInput{
-		ClusterId: aws.String(d.Id()),
+		ClusterId:  aws.String(d.Id()),
+		StepStates: stepStates,
 	}
 	err = emrconn.ListStepsPages(listStepsInput, func(page *emr.ListStepsOutput, lastPage bool) bool {
 		// ListSteps returns steps in reverse order (newest first)