azurerm_log_profile wait for stable state

azurerm/resource_arm_monitor_log_profile.go

@@ -152,9 +152,19 @@ func resourceArmLogProfileCreateUpdate(d *schema.ResourceData, meta interface{})
 			duration = d.Timeout(schema.TimeoutUpdate)
 		}
 	}
-	// Wait for Log Profile to become available
-	if err := resource.Retry(duration, retryLogProfilesClientGet(ctx, client, name, meta)); err != nil {
-		return fmt.Errorf("Error waiting for Log Profile %q to become available: %+v", name, err)
+
+	log.Printf("[DEBUG] Waiting for Log Profile %q to be provisioned", name)
+	stateConf := &resource.StateChangeConf{
+		Pending:                   []string{"NotFound"},
+		Target:                    []string{"Available"},
+		Refresh:                   logProfilesCreateRefreshFunc(ctx, client, name),
+		Timeout:                   duration,
+		MinTimeout:                15 * time.Second,
+		ContinuousTargetOccurence: 5,
+	}
+
+	if _, err := stateConf.WaitForState(); err != nil {
+		return fmt.Errorf("Error waiting for Log Profile %q to become available: %s", name, err)
 	}
 
 	read, err := client.Get(ctx, name)
@@ -310,3 +320,16 @@ func parseLogProfileNameFromID(id string) (string, error) {
 
 	return components[6], nil
 }
+
+func logProfilesCreateRefreshFunc(ctx context.Context, client *insights.LogProfilesClient, name string) resource.StateRefreshFunc {
+	return func() (interface{}, string, error) {
+		logProfile, err := client.Get(ctx, name)
+		if err != nil {
+			if utils.ResponseWasNotFound(logProfile.Response) {
+				return nil, "NotFound", nil
+			}
+			return nil, "", fmt.Errorf("Error issuing read request in logProfilesCreateRefreshFunc for Log profile %q: %s", name, err)
+		}
+		return "Available", "Available", nil
+	}
+}