Skip to content

Commit f707cd2

Browse files
committed
rename argument
1 parent 4fd2a3d commit f707cd2

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

rust/operator-binary/src/connect/executor.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ pub enum Error {
100100
pub fn executor_pod_template(
101101
scs: &v1alpha1::SparkConnectServer,
102102
config: &v1alpha1::ExecutorConfig,
103-
pi: &ResolvedProductImage,
103+
resolved_product_image: &ResolvedProductImage,
104104
config_map: &ConfigMap,
105105
) -> Result<PodTemplateSpec, Error> {
106106
let container_env = executor_env(
@@ -123,7 +123,7 @@ pub fn executor_pod_template(
123123
let metadata = ObjectMetaBuilder::new()
124124
.with_recommended_labels(common::labels(
125125
scs,
126-
&pi.app_version_label,
126+
&resolved_product_image.app_version_label,
127127
&SparkConnectRole::Executor.to_string(),
128128
))
129129
.context(PodTemplateMetadataBuildSnafu)?
@@ -201,9 +201,9 @@ fn executor_env(env_overrides: Option<&HashMap<String, String>>) -> Result<Vec<E
201201
pub fn executor_properties(
202202
scs: &v1alpha1::SparkConnectServer,
203203
config: &v1alpha1::ExecutorConfig,
204-
pi: &ResolvedProductImage,
204+
resolved_product_image: &ResolvedProductImage,
205205
) -> Result<BTreeMap<String, Option<String>>, Error> {
206-
let spark_image = pi.image.clone();
206+
let spark_image = resolved_product_image.image.clone();
207207

208208
let mut result: BTreeMap<String, Option<String>> = [
209209
(

rust/operator-binary/src/connect/server.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -478,10 +478,10 @@ pub fn server_properties(
478478
config: &v1alpha1::ServerConfig,
479479
driver_service: &Service,
480480
service_account: &ServiceAccount,
481-
pi: &ResolvedProductImage,
481+
resolved_product_image: &ResolvedProductImage,
482482
) -> Result<BTreeMap<String, Option<String>>, Error> {
483-
let spark_image = pi.image.clone();
484-
let spark_version = pi.product_version.clone();
483+
let spark_image = resolved_product_image.image.clone();
484+
let spark_version = resolved_product_image.product_version.clone();
485485
let service_account_name = service_account.name_unchecked();
486486
let namespace = driver_service
487487
.namespace()

0 commit comments

Comments
 (0)