diff --git a/lib/data_layer.ex b/lib/data_layer.ex index 07668d1..2e2bb36 100644 --- a/lib/data_layer.ex +++ b/lib/data_layer.ex @@ -1139,7 +1139,7 @@ defmodule AshPostgres.DataLayer do end defp simple_operator_expr(op, params, value, type, current_binding, attribute, false) do - {params ++ [{value, Ash.Type.ecto_type(type)}], + {params ++ [{value, op_type(type)}], {op, [], [ {{:., [], [{:&, [], [current_binding]}, attribute]}, [], []}, @@ -1156,6 +1156,14 @@ defmodule AshPostgres.DataLayer do ]}} end + defp op_type({:in, type}) do + {:in, op_type(type)} + end + + defp op_type(type) do + Ash.Type.ecto_type(type) + end + defp tagged(value, type) do %Ecto.Query.Tagged{value: value, type: get_type(type)} end