Skip to content

Commit 929c01d

Browse files
Apply suggestions from code review
Co-authored-by: Nick <10092581+NickLarsenNZ@users.noreply.github.com>
1 parent cc27605 commit 929c01d

1 file changed

Lines changed: 4 additions & 14 deletions

File tree

rust/operator-binary/src/airflow_controller.rs

Lines changed: 4 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1059,20 +1059,15 @@ fn build_server_rolegroup_statefulset(
10591059
}
10601060

10611061
if merged_airflow_config.logging.enable_vector_agent {
1062-
match airflow
1063-
.spec
1064-
.cluster_config
1065-
.vector_aggregator_config_map_name
1066-
.to_owned()
1067-
{
1062+
match &airflow.spec.cluster_config.vector_aggregator_config_map_name {
10681063
Some(vector_aggregator_config_map_name) => {
10691064
pb.add_container(build_logging_container(
10701065
resolved_product_image,
10711066
merged_airflow_config
10721067
.logging
10731068
.containers
10741069
.get(&Container::Vector),
1075-
&vector_aggregator_config_map_name,
1070+
vector_aggregator_config_map_name,
10761071
)?);
10771072
}
10781073
None => {
@@ -1249,20 +1244,15 @@ fn build_executor_template_config_map(
12491244
}
12501245

12511246
if merged_executor_config.logging.enable_vector_agent {
1252-
match airflow
1253-
.spec
1254-
.cluster_config
1255-
.vector_aggregator_config_map_name
1256-
.to_owned()
1257-
{
1247+
match &airflow.spec.cluster_config.vector_aggregator_config_map_name {
12581248
Some(vector_aggregator_config_map_name) => {
12591249
pb.add_container(build_logging_container(
12601250
resolved_product_image,
12611251
merged_executor_config
12621252
.logging
12631253
.containers
12641254
.get(&Container::Vector),
1265-
&vector_aggregator_config_map_name,
1255+
vector_aggregator_config_map_name,
12661256
)?);
12671257
}
12681258
None => {

0 commit comments

Comments
 (0)