feat: fix error handling in kafkaClusterStatus function

AutoMQ · Aug 7, 2024 · 2b0231e · 2b0231e
1 parent 17aa14f
commit 2b0231e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/provider/util_wait.go b/internal/provider/util_wait.go
@@ -54,7 +54,7 @@ func kafkaClusterStatus(ctx context.Context, c *client.Client, clusterId string,
 			return nil, stateUnknown, err
 		}
 		if cluster == nil {
-			return nil, stateUnknown, fmt.Errorf("Kafka Cluster %q not found", cluster)
+			return nil, stateUnknown, fmt.Errorf("Kafka Cluster %q not found", cluster.InstanceID)
 		}
 
 		tflog.Debug(ctx, fmt.Sprintf("Waiting for Kafka Cluster %q status to become %q: current status is %q", clusterId, targetState, cluster.Status))