Skip to content

Commit 9624341

Browse files
committed
feat(snowflake): use upstream array_sort
1 parent 186b61e commit 9624341

File tree

2 files changed

+1
-6
lines changed

2 files changed

+1
-6
lines changed

ibis/backends/snowflake/__init__.py

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -110,11 +110,6 @@ class SnowflakeCompiler(AlchemyCompiler):
110110
return Object.assign(...keys.map((key, j) => ({[key]: arrays[j][i]})));
111111
})""",
112112
},
113-
"ibis_udfs.public.array_sort": {
114-
"inputs": {"array": ARRAY},
115-
"returns": ARRAY,
116-
"source": """return array.sort();""",
117-
},
118113
"ibis_udfs.public.array_repeat": {
119114
# Integer inputs are not allowed because JavaScript only supports
120115
# doubles

ibis/backends/snowflake/registry.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -420,7 +420,7 @@ def _timestamp_bucket(t, op):
420420
ops.ArrayRemove: fixed_arity(sa.func.array_remove, 2),
421421
ops.ArrayIntersect: fixed_arity(sa.func.array_intersection, 2),
422422
ops.ArrayZip: _array_zip,
423-
ops.ArraySort: unary(sa.func.ibis_udfs.public.array_sort),
423+
ops.ArraySort: unary(sa.func.array_sort),
424424
ops.ArrayRepeat: fixed_arity(sa.func.ibis_udfs.public.array_repeat, 2),
425425
ops.StringSplit: fixed_arity(sa.func.split, 2),
426426
# snowflake typeof only accepts VARIANT, so we cast

0 commit comments

Comments
 (0)