Skip to content

Commit cfc542a

Browse files
committed
Chore: Fix rustfmt errors
1 parent 6f2e0f8 commit cfc542a

1 file changed

Lines changed: 18 additions & 17 deletions

File tree

rust/operator-binary/src/controller.rs

Lines changed: 18 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -527,25 +527,26 @@ pub async fn reconcile_trino(
527527
}
528528

529529
if let Some(listener_class) = trino_role.listener_class_name(trino)
530-
&& let Some(listener_group_name) = group_listener_name(trino, &trino_role) {
531-
let role_group_listener = build_group_listener(
530+
&& let Some(listener_group_name) = group_listener_name(trino, &trino_role)
531+
{
532+
let role_group_listener = build_group_listener(
533+
trino,
534+
build_recommended_labels(
532535
trino,
533-
build_recommended_labels(
534-
trino,
535-
&validated.image.app_version_label_value,
536-
&trino_role_str,
537-
"none",
538-
),
539-
listener_class.to_string(),
540-
listener_group_name,
541-
)
542-
.context(ListenerConfigurationSnafu)?;
536+
&validated.image.app_version_label_value,
537+
&trino_role_str,
538+
"none",
539+
),
540+
listener_class.to_string(),
541+
listener_group_name,
542+
)
543+
.context(ListenerConfigurationSnafu)?;
543544

544-
cluster_resources
545-
.add(client, role_group_listener)
546-
.await
547-
.context(ApplyGroupListenerSnafu)?;
548-
}
545+
cluster_resources
546+
.add(client, role_group_listener)
547+
.await
548+
.context(ApplyGroupListenerSnafu)?;
549+
}
549550

550551
let role_config = trino.generic_role_config(&trino_role);
551552
if let Some(GenericRoleConfig {

0 commit comments

Comments
 (0)