gistfile1.txt

** (FunctionClauseError) no function clause matching in Ecto.Adapters.Postgres.Connection.boolean/4
    (ecto) lib/ecto/adapters/postgres/connection.ex:402: Ecto.Adapters.Postgres.Connection.boolean(" WHERE ", [%Ecto.Query.QueryExpr{expr: {:==, [], [{{:., [], [{:&, [], [0]}, :unique_identifier]}, [], []}, {:^, [], [0]}]}, file: "/Users/Aidy/Documents/Work/Web/Manage Places/travel_guardian/apps/feed_aggregator/lib/feed_aggregator/db_runner.ex", line: 60, params: nil}], {{[34, "schedule_entries", 34], ["s" | "0"], nil}}, %Inspect.Error{message: "got FunctionClauseError with message \"no function clause matching in anonymous fn/1 in Inspect.Ecto.Query.bool_exprs/3\" while inspecting %{__struct__: Ecto.Query, assocs: [], distinct: nil, from: {\"schedule_entries\", nil}, group_bys: [], havings: [], joins: [], limit: nil, lock: nil, offset: nil, order_bys: [], prefix: nil, preloads: [], select: nil, sources: {{\"schedule_entries\", nil}}, updates: [], wheres: [%Ecto.Query.QueryExpr{expr: {:==, [], [{{:., [], [{:&, [], [0]}, :unique_identifier]}, [], []}, {:^, [], [0]}]}, file: \"/Users/Aidy/Documents/Work/Web/Manage Places/travel_guardian/apps/feed_aggregator/lib/feed_aggregator/db_runner.ex\", line: 60, params: nil}]}"})
    (ecto) lib/ecto/adapters/postgres/connection.ex:161: Ecto.Adapters.Postgres.Connection.delete_all/1
    (ecto) lib/ecto/adapters/postgres.ex:86: Ecto.Adapters.Postgres.prepare/2
    (ecto) lib/ecto/query/planner.ex:176: Ecto.Query.Planner.query_without_cache/4
    (ecto) lib/ecto/query/planner.ex:145: Ecto.Query.Planner.query_prepare/6
    (ecto) lib/ecto/query/planner.ex:119: Ecto.Query.Planner.query_with_cache/7
    (ecto) lib/ecto/repo/queryable.ex:122: Ecto.Repo.Queryable.execute/5
    (feed_aggregator) lib/feed_aggregator/db_runner.ex:45: TGFeedAggregator.DBRunner.process_db_transformations/1
    (ecto) lib/ecto/adapters/sql.ex:615: anonymous fn/3 in Ecto.Adapters.SQL.do_transaction/3
    (db_connection) lib/db_connection.ex:1274: DBConnection.transaction_run/4
    (db_connection) lib/db_connection.ex:1198: DBConnection.run_begin/3
    (db_connection) lib/db_connection.ex:789: DBConnection.transaction/3
    (feed_aggregator) lib/feed_aggregator/db_runner.ex:26: TGFeedAggregator.DBRunner.handle_events/3
    lib/gen_stage.ex:2401: Experimental.GenStage.consumer_dispatch/7
    lib/gen_stage.ex:1955: Experimental.GenStage.handle_info/2
    (stdlib) gen_server.erl:615: :gen_server.try_dispatch/4
    (stdlib) gen_server.erl:681: :gen_server.handle_msg/5
    (stdlib) proc_lib.erl:240: :proc_lib.init_p_do_apply/3

Query.ex

from(r in to_string(transformation.table), where: field(r, ^transformation.id_column) == ^transformation.id)
|> Repo.delete_all