first working fix

Author: Maleware

rust/operator-binary/src/airflow_controller.rs

@@ -514,23 +514,20 @@ pub async fn reconcile_airflow(
             )
             .context(LabelBuildSnafu)?;
 
-            // Only apply headless service for something exposing an HTTP port
-            if airflow_role.get_http_port().is_some() {
-                let rg_headless_service = build_rolegroup_headless_service(
-                    airflow,
-                    &rolegroup,
-                    role_group_service_recommended_labels.clone(),
-                    role_group_service_selector.clone().into(),
-                )
-                .context(ServiceConfigurationSnafu)?;
+            let rg_headless_service = build_rolegroup_headless_service(
+                airflow,
+                &rolegroup,
+                role_group_service_recommended_labels.clone(),
+                role_group_service_selector.clone().into(),
+            )
+            .context(ServiceConfigurationSnafu)?;
 
-                cluster_resources
-                    .add(client, rg_headless_service)
-                    .await
-                    .context(ApplyRoleGroupServiceSnafu {
-                        rolegroup: rolegroup.clone(),
-                    })?;
-            }
+            cluster_resources
+                .add(client, rg_headless_service)
+                .await
+                .context(ApplyRoleGroupServiceSnafu {
+                    rolegroup: rolegroup.clone(),
+                })?;
 
             let rg_metrics_service = build_rolegroup_metrics_service(
                 airflow,

rust/operator-binary/src/service.rs

@@ -111,15 +111,19 @@ pub fn build_rolegroup_metrics_service(
 }
 
 pub fn stateful_set_service_name(
-    airflow_role: &AirflowRole,
+    _airflow_role: &AirflowRole,
     rolegroup_ref: &RoleGroupRef<v1alpha1::AirflowCluster>,
 ) -> Option<String> {
-    match airflow_role {
-        AirflowRole::Webserver => Some(rolegroup_headless_service_name(
-            &rolegroup_ref.object_name(),
-        )),
-        AirflowRole::Scheduler | AirflowRole::Worker => None,
-    }
+    //match airflow_role {
+    //AirflowRole::Webserver => Some(rolegroup_headless_service_name(
+    //&rolegroup_ref.object_name(),
+    //)),
+
+    //AirflowRole::Scheduler | AirflowRole::Worker => None,
+    //}
+    Some(rolegroup_headless_service_name(
+        &rolegroup_ref.object_name(),
+    ))
 }
 
 /// Returns the metrics rolegroup service name `<cluster>-<role>-<rolegroup>-<METRICS_SERVICE_SUFFIX>`.