1 files changed, 3 insertions, 3 deletions
diff --git a/priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs b/priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs
index 1e5a76ce9..8c1172332 100644
--- a/priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs
+++ b/priv/repo/migrations/20211218181640_resolve_activity_object_conflicts.exs
@@ -20,7 +20,7 @@ defmodule Pleroma.Repo.Migrations.ResolveActivityObjectConflicts do
 
     activity_conflict_query()
     |> Repo.stream()
-    |> Stream.each(&update_object/1)
+    |> Stream.each(&update_object!/1)
     |> Stream.run()
   end
 
@@ -30,9 +30,9 @@ defmodule Pleroma.Repo.Migrations.ResolveActivityObjectConflicts do
   end
 
   # Update the object and its relations with a newly-generated ID.
-  defp update_object(object) do
+  defp update_object!(object) do
     new_id = ObjectId.flake_from_time(object.inserted_at)
-    ObjectId.change_id(object, new_id)
+    {:ok, %Object{}} = ObjectId.change_id(object, new_id)
   end
 
   def down do