Update rust/operator-binary/src/crd/mod.rs

razvan · maltesander · web-flow · commit 59c9f3f0965b · 2025-11-12T14:14:19.000+01:00
Co-authored-by: Malte Sander &lt;contact@maltesander.com&gt;
diff --git a/rust/operator-binary/src/crd/mod.rs b/rust/operator-binary/src/crd/mod.rs
@@ -291,7 +291,7 @@ impl v1alpha1::KafkaCluster {
                 };
 
                 // If no specific role is requested, or the current role matches the requested one, add pod descriptors
-                if requested_kafka_role.is_none() || &current_role == requested_kafka_role.unwrap()
+                if requested_kafka_role.is_none() || Some(&current_role) == requested_kafka_role {
                 {
                     for replica in 0..replicas {
                         pod_descriptors.push(KafkaPodDescriptor {

Original file line number	Diff line number	Diff line change
`@@ -291,7 +291,7 @@ impl v1alpha1::KafkaCluster {`
`291`	`291`	`};`
`292`	`292`
`293`	`293`	`// If no specific role is requested, or the current role matches the requested one, add pod descriptors`
`294`		`- if requested_kafka_role.is_none() \|\| &current_role == requested_kafka_role.unwrap()`
	`294`	`+ if requested_kafka_role.is_none() \|\| Some(&current_role) == requested_kafka_role {`
`295`	`295`	`{`
`296`	`296`	`for replica in 0..replicas {`
`297`	`297`	`pod_descriptors.push(KafkaPodDescriptor {`