feat(snowflake): implement TimestampFromUNIX

ibis/backends/snowflake/registry.py

@@ -95,7 +95,6 @@ def _extract_url_query(t, op):
     return sa.func.nullif(sa.func.as_varchar(r), "")
 
 
-<<<<<<< HEAD
 def _array_slice(t, op):
     arg = t.translate(op.arg)
 
@@ -124,6 +123,8 @@ def _map(_, op):
     )
 
 
+_TIMESTAMP_UNITS_TO_SCALE = {"s": 0, "ms": 3, "us": 6, "ns": 9}
+
 _SF_POS_INF = sa.func.to_double("Inf")
 _SF_NEG_INF = sa.func.to_double("-Inf")
 _SF_NAN = sa.func.to_double("NaN")
@@ -234,6 +235,9 @@ def _map(_, op):
             1,
         ),
         ops.TimestampFromYMDHMS: fixed_arity(sa.func.timestamp_from_parts, 6),
+        ops.TimestampFromUNIX: lambda t, op: sa.func.to_timestamp(
+            t.translate(op.arg), _TIMESTAMP_UNITS_TO_SCALE[op.unit]
+        ),
     }
 )
 
@@ -256,7 +260,6 @@ def _map(_, op):
     # ibis.expr.operations.temporal
     ops.IntervalFromInteger,
     ops.TimestampDiff,
-    ops.TimestampFromUNIX,
 }
 
 operation_registry = {

ibis/backends/tests/test_temporal.py

@@ -605,7 +605,7 @@ def test_strftime(backend, alltypes, df, expr_fn, pandas_pattern):
         ),
     ],
 )
-@pytest.mark.notimpl(["datafusion", "mysql", "postgres", "sqlite", "snowflake"])
+@pytest.mark.notimpl(["datafusion", "mysql", "postgres", "sqlite"])
 def test_integer_to_timestamp(backend, con, unit):
     backend_unit = backend.returned_timestamp_unit
     factor = unit_factors[unit]

ibis/expr/operations/temporal.py

@@ -254,7 +254,6 @@ class TimestampFromYMDHMS(Value):
 @public
 class TimestampFromUNIX(Value):
     arg = rlz.any
-    # Only pandas-based backends support 'ns'
     unit = rlz.isin({'s', 'ms', 'us', 'ns'})
 
     output_dtype = dt.timestamp