Support domain extraction for columns with escaped dots in their names

.github/workflows/build_test.yml

@@ -319,7 +319,7 @@ jobs:
           ls -la
           python -m pip install vegafusion-*.whl
           python -m pip install vegafusion_python_embed-*manylinux_2_17_x86_64*.whl
-          python -m pip install pytest vega-datasets polars duckdb "vl-convert-python>=1.0.1rc1" scikit-image pandas==2.0
+          python -m pip install pytest vega-datasets polars duckdb==0.9.2 "vl-convert-python>=1.0.1rc1" scikit-image pandas==2.0
       - name: Test vegafusion
         working-directory: python/vegafusion/
         run: pytest
@@ -350,7 +350,7 @@ jobs:
           ls -la
           python -m pip install vegafusion-*.whl
           python -m pip install vegafusion_python_embed-*macosx_10_*_x86_64.whl
-          python -m pip install pytest vega-datasets polars duckdb vl-convert-python scikit-image pandas==2.0
+          python -m pip install pytest vega-datasets polars duckdb==0.9.2 vl-convert-python scikit-image pandas==2.0
           python -m pip install pyarrow==10.0 altair==5.1.2
       - name: Test vegafusion
         working-directory: python/vegafusion/
@@ -386,7 +386,7 @@ jobs:
 
           python -m pip install $vegafusion
           python -m pip install $vegafusion_python_embed
-          python -m pip install pytest vega-datasets polars duckdb vl-convert-python scikit-image
+          python -m pip install pytest vega-datasets polars duckdb==0.9.2 vl-convert-python scikit-image
       - name: Test vegafusion
         working-directory: python/vegafusion/
         run: pytest

vegafusion-core/src/planning/split_domain_data.rs

@@ -40,14 +40,18 @@ pub struct SplitScaleDomainVisitor<'a> {
     pub task_scope: &'a TaskScope,
     pub new_datasets: Vec<(Vec<u32>, DataSpec)>,
     pub domain_dataset_fields: HashMap<ScopedVariable, (ScopedVariable, String)>,
+    pub nested_regex: regex::Regex,
 }
 
 impl<'a> SplitScaleDomainVisitor<'a> {
     pub fn new(task_scope: &'a TaskScope) -> Self {
+        // Regex matching unescaped dot characters
+        let nested_regex = regex::Regex::new(r#"[^\\]\."#).unwrap();
         Self {
             new_datasets: Vec::new(),
             task_scope,
             domain_dataset_fields: Default::default(),
+            nested_regex,
         }
     }
 }
@@ -173,7 +177,7 @@ impl<'a> SplitScaleDomainVisitor<'a> {
         let field_name = &field_ref.field;
 
         // Validate whether we can do anything
-        if field_name.contains('.') {
+        if self.nested_regex.is_match(field_name) {
             // Nested fields not supported
             return Ok(());
         }

vegafusion-runtime/tests/specs/custom/gh_455.comm_plan.json

@@ -0,0 +1,25 @@
+{
+  "server_to_client": [
+    {
+      "name": "data_0",
+      "namespace": "data",
+      "scope": []
+    },
+    {
+      "name": "data_0_layer_0_layer_0_color_domain_sym\\.bol",
+      "namespace": "data",
+      "scope": []
+    },
+    {
+      "name": "data_0_x_domain_sym\\.bol",
+      "namespace": "data",
+      "scope": []
+    },
+    {
+      "name": "data_0_y_domain_sum_price",
+      "namespace": "data",
+      "scope": []
+    }
+  ],
+  "client_to_server": []
+}