feat(core): upgrade DataFusion to support the array of struct syntax (#…

…956)
Canner · Nov 28, 2024 · 689caf8 · 689caf8
1 parent 2dce8b7
commit 689caf8
Show file tree

Hide file tree

Showing 13 changed files with 182 additions and 122 deletions.
diff --git a/ibis-server/tests/conftest.py b/ibis-server/tests/conftest.py
@@ -5,4 +5,4 @@ def file_path(path: str) -> str:
     return os.path.join(os.path.dirname(__file__), path)
 
 
-DATAFUSION_FUNCTION_COUNT = 269
+DATAFUSION_FUNCTION_COUNT = 270
diff --git a/ibis-server/tests/routers/v3/connector/bigquery/test_functions.py b/ibis-server/tests/routers/v3/connector/bigquery/test_functions.py
@@ -47,7 +47,7 @@ def test_function_list():
         response = client.get(url=f"{base_url}/functions")
         assert response.status_code == 200
         result = response.json()
-        assert len(result) == DATAFUSION_FUNCTION_COUNT + 34
+        assert len(result) == DATAFUSION_FUNCTION_COUNT + 33
         the_func = next(filter(lambda x: x["name"] == "abs", result))
         assert the_func == {
             "name": "abs",

diff --git a/ibis-server/tests/routers/v3/connector/postgres/test_functions.py b/ibis-server/tests/routers/v3/connector/postgres/test_functions.py
@@ -57,7 +57,7 @@ def test_function_list():
         response = client.get(url=f"{base_url}/functions")
         assert response.status_code == 200
         result = response.json()
-        assert len(result) == DATAFUSION_FUNCTION_COUNT + 49
+        assert len(result) == DATAFUSION_FUNCTION_COUNT + 48
         the_func = next(filter(lambda x: x["name"] == "abs", result))
         assert the_func == {
             "name": "abs",

diff --git a/ibis-server/tests/routers/v3/connector/snowflake/test_functions.py b/ibis-server/tests/routers/v3/connector/snowflake/test_functions.py
@@ -57,7 +57,7 @@ def test_function_list():
         response = client.get(url=f"{base_url}/functions")
         assert response.status_code == 200
         result = response.json()
-        assert len(result) == DATAFUSION_FUNCTION_COUNT + 71
+        assert len(result) == DATAFUSION_FUNCTION_COUNT + 70
         the_func = next(filter(lambda x: x["name"] == "abs", result))
         assert the_func == {
             "name": "abs",
Original file line number	Diff line number	Diff line change
Expand Up		@@ -5,4 +5,4 @@ def file_path(path: str) -> str:
		return os.path.join(os.path.dirname(__file__), path)


		DATAFUSION_FUNCTION_COUNT = 269
		DATAFUSION_FUNCTION_COUNT = 270