create queue if necessary

Author: nikola-jokic

third_party/airflow/test/integration/test_airflow_operator_logic.py

@@ -57,6 +57,17 @@ def no_auth_client() -> ArmadaClient:
     return ArmadaClient(channel=grpc.insecure_channel(f"{server_name}:{server_port}"))
 
 
+# Ensure DEFAULT_QUEUE exists before any tests run
+@pytest.fixture(scope="session", autouse=True)
+def ensure_default_queue(client: ArmadaClient):
+    try:
+        client.get_queue(DEFAULT_QUEUE)
+    except grpc.RpcError:
+        # Create queue with default params if missing
+        q = client.create_queue_request(name=DEFAULT_QUEUE, priority_factor=1.0)
+        client.create_queue(q)
+
+
 def sleep_pod(image: str):
     pod = core_v1.PodSpec(
         containers=[