rustfmt update

Author: lfrancke

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

@@ -827,11 +827,14 @@ impl v1alpha1::SparkApplication {
         };
         if let Some(role_envs) = role_envs {
             env.extend(role_envs.iter().map(|(k, v)| {
-                (k, EnvVar {
-                    name: k.clone(),
-                    value: Some(v.clone()),
-                    ..Default::default()
-                })
+                (
+                    k,
+                    EnvVar {
+                        name: k.clone(),
+                        value: Some(v.clone()),
+                        ..Default::default()
+                    },
+                )
             }))
         }
 
@@ -889,10 +892,13 @@ impl v1alpha1::SparkApplication {
                 Role {
                     config: submit_conf.clone(),
                     role_config: GenericRoleConfig::default(),
-                    role_groups: [("default".to_string(), RoleGroup {
-                        config: submit_conf,
-                        replicas: Some(1),
-                    })]
+                    role_groups: [(
+                        "default".to_string(),
+                        RoleGroup {
+                            config: submit_conf,
+                            replicas: Some(1),
+                        },
+                    )]
                     .into(),
                 }
                 .erase(),
@@ -909,10 +915,13 @@ impl v1alpha1::SparkApplication {
                 Role {
                     config: driver_conf.clone(),
                     role_config: GenericRoleConfig::default(),
-                    role_groups: [("default".to_string(), RoleGroup {
-                        config: driver_conf,
-                        replicas: Some(1),
-                    })]
+                    role_groups: [(
+                        "default".to_string(),
+                        RoleGroup {
+                            config: driver_conf,
+                            replicas: Some(1),
+                        },
+                    )]
                     .into(),
                 }
                 .erase(),

rust/operator-binary/src/main.rs

@@ -109,10 +109,13 @@ async fn main() -> anyhow::Result<()> {
                 client: client.clone(),
                 product_config: product_config.load(&PRODUCT_CONFIG_PATHS)?,
             };
-            let spark_event_recorder = Arc::new(Recorder::new(client.as_kube_client(), Reporter {
-                controller: SPARK_FULL_CONTROLLER_NAME.to_string(),
-                instance: None,
-            }));
+            let spark_event_recorder = Arc::new(Recorder::new(
+                client.as_kube_client(),
+                Reporter {
+                    controller: SPARK_FULL_CONTROLLER_NAME.to_string(),
+                    instance: None,
+                },
+            ));
             let app_controller = Controller::new(
                 watch_namespace
                     .get_api::<DeserializeGuard<crd::v1alpha1::SparkApplication>>(&client),
@@ -147,11 +150,13 @@ async fn main() -> anyhow::Result<()> {
                 },
             );
 
-            let pod_driver_event_recorder =
-                Arc::new(Recorder::new(client.as_kube_client(), Reporter {
+            let pod_driver_event_recorder = Arc::new(Recorder::new(
+                client.as_kube_client(),
+                Reporter {
                     controller: POD_DRIVER_FULL_CONTROLLER_NAME.to_string(),
                     instance: None,
-                }));
+                },
+            ));
             let pod_driver_controller = Controller::new(
                 watch_namespace.get_api::<DeserializeGuard<Pod>>(&client),
                 watcher::Config::default()
@@ -191,11 +196,13 @@ async fn main() -> anyhow::Result<()> {
                 client: client.clone(),
                 product_config: product_config.load(&PRODUCT_CONFIG_PATHS)?,
             };
-            let history_event_recorder =
-                Arc::new(Recorder::new(client.as_kube_client(), Reporter {
+            let history_event_recorder = Arc::new(Recorder::new(
+                client.as_kube_client(),
+                Reporter {
                     controller: HISTORY_FULL_CONTROLLER_NAME.to_string(),
                     instance: None,
-                }));
+                },
+            ));
             let history_controller = Controller::new(
                 watch_namespace
                     .get_api::<DeserializeGuard<crd::history::v1alpha1::SparkHistoryServer>>(
@@ -253,11 +260,13 @@ async fn main() -> anyhow::Result<()> {
                 client: client.clone(),
                 product_config: product_config.load(&PRODUCT_CONFIG_PATHS)?,
             };
-            let connect_event_recorder =
-                Arc::new(Recorder::new(client.as_kube_client(), Reporter {
+            let connect_event_recorder = Arc::new(Recorder::new(
+                client.as_kube_client(),
+                Reporter {
                     controller: CONNECT_FULL_CONTROLLER_NAME.to_string(),
                     instance: None,
-                }));
+                },
+            ));
             let connect_controller = Controller::new(
                 watch_namespace
                     .get_api::<DeserializeGuard<connect::crd::v1alpha1::SparkConnectServer>>(

rust/operator-binary/src/pod_driver_controller.rs

@@ -99,9 +99,13 @@ pub async fn reconcile(pod: Arc<DeserializeGuard<Pod>>, client: Arc<Client>) ->
     tracing::info!("Update spark application [{app_name}] status to [{phase}]");
 
     client
-        .apply_patch_status(POD_DRIVER_CONTROLLER_NAME, &app, &SparkApplicationStatus {
-            phase: phase.clone(),
-        })
+        .apply_patch_status(
+            POD_DRIVER_CONTROLLER_NAME,
+            &app,
+            &SparkApplicationStatus {
+                phase: phase.clone(),
+            },
+        )
         .await
         .with_context(|_| ApplySparkApplicationStatusSnafu {
             name: app_name.clone(),