diff --git a/lib/ash/actions/destroy/bulk.ex b/lib/ash/actions/destroy/bulk.ex
index 66318442c..957df86e6 100644
--- a/lib/ash/actions/destroy/bulk.ex
+++ b/lib/ash/actions/destroy/bulk.ex
@@ -539,6 +539,7 @@ defmodule Ash.Actions.Destroy.Bulk do
            authorize_bulk_query(query, atomic_changeset, opts),
          {:ok, atomic_changeset, query} <-
            authorize_atomic_changeset(query, atomic_changeset, opts),
+         {query, atomic_changeset} <- add_changeset_filters(query, atomic_changeset),
          {:ok, data_layer_query} <- Ash.Query.data_layer_query(query) do
       case Ash.DataLayer.destroy_query(
              data_layer_query,
@@ -767,6 +768,10 @@ defmodule Ash.Actions.Destroy.Bulk do
     end
   end
 
+  defp add_changeset_filters(query, changeset) do
+    {Ash.Query.do_filter(query, changeset.filter), %{changeset | filter: nil}}
+  end
+
   defp do_run(domain, stream, action, input, opts, not_atomic_reason) do
     resource = opts[:resource]
     opts = Ash.Actions.Helpers.set_opts(opts, domain)
@@ -1093,6 +1098,7 @@ defmodule Ash.Actions.Destroy.Bulk do
 
     resource
     |> Ash.Changeset.new()
+    |> Ash.Changeset.filter(opts[:filter])
     |> Map.put(:domain, domain)
     |> Ash.Actions.Helpers.add_context(opts)
     |> Ash.Changeset.set_context(opts[:context] || %{})
diff --git a/lib/ash/actions/update/bulk.ex b/lib/ash/actions/update/bulk.ex
index 2e9c3be63..5efe39c12 100644
--- a/lib/ash/actions/update/bulk.ex
+++ b/lib/ash/actions/update/bulk.ex
@@ -495,6 +495,8 @@ defmodule Ash.Actions.Update.Bulk do
            authorize_bulk_query(query, atomic_changeset, opts),
          {:ok, atomic_changeset, query} <-
            authorize_atomic_changeset(query, atomic_changeset, opts),
+         {query, atomic_changeset} <-
+           add_changeset_filters(query, atomic_changeset),
          %Ash.Changeset{valid?: true} = atomic_changeset <-
            Ash.Changeset.handle_allow_nil_atomics(atomic_changeset, opts[:actor]),
          atomic_changeset <- sort_atomic_changes(atomic_changeset),
@@ -1056,6 +1058,7 @@ defmodule Ash.Actions.Update.Bulk do
         )
         |> Ash.Query.set_context(%{private: %{internal?: true}})
         |> Ash.Query.filter(^pkeys)
+        |> Ash.Query.filter(^atomic_changeset.filter)
         |> Ash.Query.select([])
         |> then(fn query ->
           run(domain, query, action.name, input,
@@ -1373,6 +1376,10 @@ defmodule Ash.Actions.Update.Bulk do
     |> Enum.with_index()
   end
 
+  defp add_changeset_filters(query, changeset) do
+    {Ash.Query.do_filter(query, changeset.filter), %{changeset | filter: nil}}
+  end
+
   defp pre_template(opts, changeset, actor) do
     if Ash.Expr.template_references_context?(opts) do
       opts
diff --git a/lib/ash/changeset/changeset.ex b/lib/ash/changeset/changeset.ex
index 18195e19e..a25f2f6d7 100644
--- a/lib/ash/changeset/changeset.ex
+++ b/lib/ash/changeset/changeset.ex
@@ -2429,47 +2429,33 @@ defmodule Ash.Changeset do
              )}
 
           :error ->
-            if changeset.action.type == :update || Map.get(changeset.action, :soft?) do
-              [first_pkey_field | _] = Ash.Resource.Info.primary_key(changeset.resource)
+            [first_pkey_field | _] = Ash.Resource.Info.primary_key(changeset.resource)
 
-              full_atomic_update =
-                expr(
-                  if ^condition_expr do
-                    ^error_expr
-                  else
-                    ^atomic_ref(changeset, first_pkey_field)
-                  end
-                )
+            full_atomic_update =
+              expr(
+                if ^condition_expr do
+                  ^error_expr
+                else
+                  ^atomic_ref(changeset, first_pkey_field)
+                end
+              )
 
-              case Ash.Filter.hydrate_refs(full_atomic_update, %{
-                     resource: changeset.resource,
-                     public: false
-                   }) do
-                {:ok, full_atomic_update} ->
-                  {:cont,
-                   atomic_update(
-                     changeset,
-                     first_pkey_field,
-                     full_atomic_update
-                   )}
+            case Ash.Filter.hydrate_refs(full_atomic_update, %{
+                   resource: changeset.resource,
+                   public: false
+                 }) do
+              {:ok, full_atomic_update} ->
+                {:cont,
+                 atomic_update(
+                   changeset,
+                   first_pkey_field,
+                   full_atomic_update
+                 )}
 
-                {:error, error} ->
-                  {:halt,
-                   {:not_atomic,
-                    "Failed to validate expression #{inspect(full_atomic_update)}: #{inspect(error)}"}}
-              end
-            else
-              {:cont,
-               filter(
-                 changeset,
-                 expr(
-                   if ^condition_expr do
-                     ^error_expr
-                   else
-                     true
-                   end
-                 )
-               )}
+              {:error, error} ->
+                {:halt,
+                 {:not_atomic,
+                  "Failed to validate expression #{inspect(full_atomic_update)}: #{inspect(error)}"}}
             end
         end
       else
diff --git a/lib/ash/data_layer/ets/ets.ex b/lib/ash/data_layer/ets/ets.ex
index 6abb99a33..86f14914c 100644
--- a/lib/ash/data_layer/ets/ets.ex
+++ b/lib/ash/data_layer/ets/ets.ex
@@ -1235,14 +1235,6 @@ defmodule Ash.DataLayer.Ets do
     log_destroy_query(resource, query)
 
     query
-    |> Map.update!(:filter, fn filter ->
-      if is_nil(changeset.filter) do
-        filter
-      else
-        filter = filter || %Ash.Filter{resource: changeset.resource}
-        Ash.Filter.add_to_filter!(filter, changeset.filter)
-      end
-    end)
     |> run_query(resource)
     |> case do
       {:ok, results} ->
diff --git a/test/actions/bulk/bulk_destroy_test.exs b/test/actions/bulk/bulk_destroy_test.exs
index 4e7c0aebd..0f7eb687b 100644
--- a/test/actions/bulk/bulk_destroy_test.exs
+++ b/test/actions/bulk/bulk_destroy_test.exs
@@ -129,10 +129,6 @@ defmodule Ash.Test.Actions.BulkDestroyTest do
         end
       end
 
-      destroy :destroy_with_validation do
-        validate attribute_does_not_equal(:title, "can't delete")
-      end
-
       destroy :destroy_with_argument do
         require_atomic? false
 
@@ -429,29 +425,6 @@ defmodule Ash.Test.Actions.BulkDestroyTest do
     assert [] = Ash.read!(Post)
   end
 
-  test "runs validations" do
-    assert_raise Ash.Error.Invalid, ~r/must not equal "can't delete"/, fn ->
-      assert %Ash.BulkResult{
-               records: [
-                 %{title: "title1", title2: nil},
-                 %{title: "title2", title2: nil}
-               ]
-             } =
-               Ash.bulk_create!([%{title: "can't delete"}, %{title: "title2"}], Post, :create,
-                 return_stream?: true,
-                 return_records?: true
-               )
-               |> Stream.map(fn {:ok, result} ->
-                 result
-               end)
-               |> Ash.bulk_destroy!(:destroy_with_validation, %{},
-                 resource: Post,
-                 return_records?: true,
-                 return_errors?: true
-               )
-    end
-  end
-
   test "runs after batch hooks" do
     assert %Ash.BulkResult{
              records: [