fix: Bump stackable-operator for delayed controller functionality (#759)

* fix: Delay controller startup to avoid 404 in initial list

* chore: Add changelog entry

Author: Techassi

CHANGELOG.md

@@ -12,13 +12,13 @@
 
 ### Changed
 
-- Bump stackable-operator to 0.106.2, strum to 0.28, and rand to 0.10 ([#752]).
+- Bump stackable-operator to 0.108.0, strum to 0.28, and rand to 0.10 ([#752], [#759]).
 - Gracefully shutdown all concurrent tasks by forwarding the SIGTERM signal ([#741]).
 - Bump testing-tools to `0.3.0-stackable0.0.0-dev` ([#733]).
 
 ### Fixed
 
-- Fix "404 page not found" error for the initial object list ([#756]).
+- Fix "404 page not found" error for the initial object list ([#756], [#759]).
 - Default `API_WORKERS` to 1 (instead of letting Airflow default to 4) to prevent crashloop and update/correct docs to reflect this  ([#727]).
 - Prevent unnecessary Pod restarts when initially creating an AirflowCluster.
   This is achieved by applying the StatefulSet after all ConfigMaps and Secrets that it mounts ([#734]).
@@ -32,6 +32,7 @@
 [#742]: https://github.com/stackabletech/airflow-operator/pull/742
 [#752]: https://github.com/stackabletech/airflow-operator/pull/752
 [#756]: https://github.com/stackabletech/airflow-operator/pull/756
+[#759]: https://github.com/stackabletech/airflow-operator/pull/759
 
 ## [25.11.0] - 2025-11-07
 

Cargo.lock

@@ -11,7 +11,7 @@ repository = "https://github.com/stackabletech/airflow-operator"
 
 [workspace.dependencies]
 product-config = { git = "https://github.com/stackabletech/product-config.git", tag = "0.8.0" }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", features = ["telemetry", "versioned", "webhook"], tag = "stackable-operator-0.106.2" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", features = ["crds", "webhook"], tag = "stackable-operator-0.108.0" }
 
 anyhow = "1.0"
 base64 = "0.22"

Cargo.nix

@@ -96,6 +96,9 @@ rules:
       {{- if .Values.maintenance.customResourceDefinitions.maintain }}
       - create
       - patch
+      # Required for startup condition
+      - list
+      - watch
       {{- end }}
   - apiGroups:
       - listeners.stackable.tech

Cargo.toml

@@ -17,7 +17,7 @@ use stackable_operator::{
         core::v1::{ConfigMap, Service},
     },
     kube::{
-        ResourceExt,
+        CustomResourceExt, ResourceExt,
         core::DeserializeGuard,
         runtime::{
             Controller,
@@ -29,12 +29,12 @@ use stackable_operator::{
     logging::controller::report_controller_reconciled,
     shared::yaml::SerializeOptions,
     telemetry::Tracing,
-    utils::signal::SignalWatcher,
+    utils::signal::{self, SignalWatcher},
 };
 
 use crate::{
     airflow_controller::AIRFLOW_FULL_CONTROLLER_NAME,
-    crd::{AirflowCluster, AirflowClusterVersion, OPERATOR_NAME, v1alpha2},
+    crd::{AirflowCluster, AirflowClusterVersion, OPERATOR_NAME, v1alpha1, v1alpha2},
     webhooks::conversion::create_webhook_server,
 };
 
@@ -192,7 +192,7 @@ async fn main() -> anyhow::Result<()> {
                 )
                 .map(anyhow::Ok);
 
-            let (webhook_server, initial_reconcile_rx) = create_webhook_server(
+            let webhook_server = create_webhook_server(
                 &operator_environment,
                 maintenance.disable_crd_maintenance,
                 client.as_kube_client(),
@@ -204,7 +204,8 @@ async fn main() -> anyhow::Result<()> {
                 .map_err(|err| anyhow!(err).context("failed to run webhook server"));
 
             let delayed_airflow_controller = async {
-                let _ = initial_reconcile_rx.await;
+                signal::crd_established(&client, v1alpha1::AirflowCluster::crd_name(), None)
+                    .await?;
                 airflow_controller.await
             };
 

crate-hashes.json

@@ -7,7 +7,6 @@ use stackable_operator::{
         webhooks::{ConversionWebhook, ConversionWebhookOptions},
     },
 };
-use tokio::sync::oneshot;
 
 use crate::crd::{AirflowCluster, AirflowClusterVersion, FIELD_MANAGER};
 
@@ -27,7 +26,7 @@ pub async fn create_webhook_server(
     operator_environment: &OperatorEnvironmentOptions,
     disable_crd_maintenance: bool,
     client: Client,
-) -> Result<(WebhookServer, oneshot::Receiver<()>), Error> {
+) -> Result<WebhookServer, Error> {
     let crds_and_handlers = vec![(
         AirflowCluster::merged_crd(AirflowClusterVersion::V1Alpha2).context(MergeCrdSnafu)?,
         AirflowCluster::try_convert,
@@ -38,7 +37,7 @@ pub async fn create_webhook_server(
         field_manager: FIELD_MANAGER.to_owned(),
     };
 
-    let (conversion_webhook, initial_reconcile_rx) =
+    let (conversion_webhook, _initial_reconcile_rx) =
         ConversionWebhook::new(crds_and_handlers, client, conversion_webhook_options);
 
     let webhook_server_options = WebhookServerOptions {
@@ -52,5 +51,5 @@ pub async fn create_webhook_server(
             .await
             .context(CreateWebhookSnafu)?;
 
-    Ok((webhook_server, initial_reconcile_rx))
+    Ok(webhook_server)
 }