bump operator-rs, minor test fixes

Author: adwk67

Cargo.toml

@@ -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.101.1" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", features = ["telemetry", "versioned", "webhook"], tag = "stackable-operator-0.101.2" }
 
 anyhow = "1.0"
 base64 = "0.22"

tests/templates/kuttl/versioning/30-install-airflow-cluster.yaml.j2

@@ -53,6 +53,7 @@ spec:
         # N.B. only works for the existing v1 field
         credentialsSecret: git-credentials
         gitFolder: "mount-dags-gitsync/dags_airflow3"
+        wait: 5s
   webservers:
     roleConfig:
       listenerClass: external-unstable

tests/templates/kuttl/versioning/dag_metrics.py

@@ -55,10 +55,17 @@ def assert_metric(role, metric):
 response = requests.patch(
     f"{rest_url}/dags/{dag_id}", headers=headers, json={"is_paused": False}
 )
+if response.status_code != 200:
+    logging.error("DAG run could not be activated")
+    sys.exit(1)
+
 # trigger DAG
 response = requests.post(
     f"{rest_url}/dags/{dag_id}/dagRuns", headers=headers, json=dag_data
 )
+if response.status_code != 200:
+    logging.error("DAG run could not be triggered")
+    sys.exit(1)
 
 # Wait for the metrics to be consumed by the statsd-exporter
 time.sleep(5)
@@ -68,8 +75,6 @@ def assert_metric(role, metric):
 loop = 0
 while True:
     try:
-        logging.info(f"Response code: {response.status_code}")
-        assert response.status_code == 200, "DAG run could not be triggered."
         # Worker is not deployed with the kubernetes executor so retrieve success metric from scheduler
         # (disable line-break flake checks)
         if (assert_metric("scheduler", "airflow_scheduler_heartbeat")) and (