build: bump airlayer to latest main (b8c734d) (#2170)

Main was pinned to v0.0.9 (tag) and 4b92e5f (rev) — both on the old
0.0.x API. Bumps to the latest main commit, which includes the
pre-aggregation rollup support introduced in v0.1.0 and the unreleased
fix for quoting column names that contain spaces.

Adapts call sites to the v0.1.x View/Topic schema:
- `View.description` / `Topic.description` are now `Option<String>`.
- `View` gained a required `pre_aggregations` field.

Co-authored-by: Claude <noreply@anthropic.com>
GitOrigin-RevId: 4d900c7461aef258f6c1fb1e5f5e221aba4eee4b

Author: 2 people

Cargo.lock

@@ -105,7 +105,7 @@ tracing = {version = "0.1.44"}
 uuid = { version = "1.23", features = ["serde", "v4"] }
 aes-gcm = "0.10.3"
 aho-corasick = "1.1"
-airlayer = { git = "https://github.com/oxy-hq/airlayer.git", tag = "v0.0.9" }
+airlayer = { git = "https://github.com/oxy-hq/airlayer.git", rev = "b8c734d" }
 anyhow = "1.0.102"
 apalis = "0.7.4"
 apalis-core = "0.7.4"

Cargo.toml

@@ -16,16 +16,16 @@ use airlayer::DatasourceDialectMap;
 
 // ── YAML shim types ──────────────────────────────────────────────────────────
 //
-// airlayer's `View` has `description: String` (non-optional) while oxy YAML
-// files may omit it.  These thin wrappers add `#[serde(default)]` where needed
-// and convert into the real airlayer types.
+// These thin wrappers add `#[serde(default)]` on optional fields and accept
+// oxy's YAML aliases (e.g. `data_source`) before converting into the real
+// airlayer types.
 
 /// Intermediate view representation for oxy YAML files.
 #[derive(Debug, Deserialize)]
 struct ViewShim {
     name: String,
     #[serde(default)]
-    description: String,
+    description: Option<String>,
     #[serde(default)]
     label: Option<String>,
     /// Oxy YAML may use `data_source` or `datasource`.
@@ -52,7 +52,7 @@ struct ViewShim {
 struct TopicShim {
     name: String,
     #[serde(default)]
-    description: String,
+    description: Option<String>,
     #[serde(default)]
     views: Vec<String>,
     #[serde(default)]
@@ -86,6 +86,7 @@ pub fn parse_view_yaml(
         dimensions: shim.dimensions,
         measures: shim.measures,
         segments: shim.segments,
+        pre_aggregations: None,
         meta: None,
     })
 }

crates/agentic/analytics/src/airlayer_compat.rs

@@ -330,10 +330,11 @@ impl SemanticCatalog {
                     .iter()
                     .map(|v_name| {
                         if let Some(view) = self.engine.view(v_name) {
-                            if view.description.is_empty() {
-                                v_name.clone()
-                            } else {
-                                format!("{} ({})", v_name, view.description)
+                            match view.description.as_deref() {
+                                Some(desc) if !desc.is_empty() => {
+                                    format!("{} ({})", v_name, desc)
+                                }
+                                _ => v_name.clone(),
                             }
                         } else {
                             v_name.clone()
@@ -343,7 +344,7 @@ impl SemanticCatalog {
                 format!(
                     "- {}: {} (views: {})",
                     t.name,
-                    t.description,
+                    t.description.as_deref().unwrap_or(""),
                     views.join(", ")
                 )
             })

crates/agentic/analytics/src/semantic/mod.rs

@@ -39,4 +39,4 @@ sea-orm-migration = { workspace = true }
 tempfile = { workspace = true }
 testcontainers = { version = "0.27", features = ["blocking", "reusable-containers"] }
 testcontainers-modules = { version = "0.15", features = ["postgres"] }
-airlayer = { git = "https://github.com/oxy-hq/airlayer.git", rev = "4b92e5f" }
+airlayer = { git = "https://github.com/oxy-hq/airlayer.git", rev = "b8c734d" }

crates/agentic/pipeline/Cargo.toml

@@ -14,7 +14,7 @@ agentic-analytics = { workspace = true }
 agentic-connector = { path = "../connector", features = [
     "duckdb", "postgres", "clickhouse", "snowflake", "bigquery"
 ] }
-airlayer = { git = "https://github.com/oxy-hq/airlayer.git", rev = "4b92e5f" }
+airlayer = { git = "https://github.com/oxy-hq/airlayer.git", rev = "b8c734d" }
 omni = { workspace = true }
 oxy-looker = { workspace = true }
 chrono = { workspace = true }

crates/agentic/workflow/Cargo.toml

@@ -127,7 +127,7 @@ fn resolve_topic(
         }
         Ok(airlayer::Topic {
             name: "adhoc_query".to_string(),
-            description: "Ad-hoc query inferred from views".to_string(),
+            description: Some("Ad-hoc query inferred from views".to_string()),
             views: view_names.into_iter().collect(),
             base_view: None,
             retrieval: None,

crates/agentic/workflow/src/semantic.rs

@@ -34,7 +34,7 @@ agentic-http = { workspace = true }
 agentic-pipeline = { workspace = true }
 agentic-runtime = { workspace = true }
 agentic-workflow = { workspace = true }
-airlayer = { git = "https://github.com/oxy-hq/airlayer.git", rev = "4b92e5f" }
+airlayer = { git = "https://github.com/oxy-hq/airlayer.git", rev = "b8c734d" }
 oxy-agent = { workspace = true }
 oxy-auth = { workspace = true }
 oxy-project = { workspace = true }

crates/app/Cargo.toml

@@ -195,7 +195,7 @@ fn validate_semantic_file(abs: &Path) -> Result<(), String> {
 struct ViewShim {
     name: String,
     #[serde(default)]
-    description: String,
+    description: Option<String>,
     #[serde(default)]
     label: Option<String>,
     #[serde(default, alias = "data_source")]
@@ -220,7 +220,7 @@ struct ViewShim {
 struct TopicShim {
     name: String,
     #[serde(default)]
-    description: String,
+    description: Option<String>,
     #[serde(default)]
     views: Vec<String>,
     #[serde(default)]
@@ -245,6 +245,7 @@ fn parse_view_yaml(yaml: &str) -> Result<airlayer::View, Box<dyn std::error::Err
         dimensions: shim.dimensions,
         measures: shim.measures,
         segments: shim.segments,
+        pre_aggregations: None,
         meta: None,
     })
 }

crates/app/src/agentic_wiring/builder_bridges/project_validator.rs

@@ -741,7 +741,7 @@ fn substitute_params(sql: &str, params: &[String]) -> String {
 fn convert_view_to_airlayer(view: &oxy_semantic::View) -> airlayer::View {
     airlayer::View {
         name: view.name.clone(),
-        description: view.description.clone().unwrap_or_default(),
+        description: view.description.clone(),
         label: view.label.clone(),
         datasource: view.datasource.clone(),
         dialect: None, // Dialect comes from datasource mapping
@@ -763,6 +763,7 @@ fn convert_view_to_airlayer(view: &oxy_semantic::View) -> airlayer::View {
             .map(|ms| ms.iter().map(convert_measure_to_airlayer).collect()),
         // TODO: pass through segments when oxy-semantic adds support
         segments: vec![],
+        pre_aggregations: None,
         meta: None,
     }
 }