diff --git a/app/jobs/activity_pub/instance_moderation_job.rb b/app/jobs/activity_pub/instance_moderation_job.rb
index 00100abf..9da0627f 100644
--- a/app/jobs/activity_pub/instance_moderation_job.rb
+++ b/app/jobs/activity_pub/instance_moderation_job.rb
@@ -9,7 +9,7 @@ class ActivityPub
     def perform(site:, hostnames:, perform_remotely: true)
       # Crear las instancias que no existan todavía
       hostnames.each do |hostname|
-        ActivityPub::Instance.find_or_create_by(hostname: hostname)
+        ActivityPub::Instance.lock.find_or_create_by(hostname: hostname)
       end
 
       instances = ActivityPub::Instance.where(hostname: hostnames)
@@ -20,7 +20,7 @@ class ActivityPub
         instances.find_each do |instance|
           # Esto bloquea cada una individualmente en la Social Inbox,
           # idealmente son pocas instancias las que aparecen.
-          site.instance_moderations.find_or_create_by(instance: instance)
+          site.instance_moderations.lock.find_or_create_by(instance: instance)
         end
 
         scope = site.instance_moderations.where(instance_id: instances.ids)
diff --git a/app/jobs/activity_pub/process_job.rb b/app/jobs/activity_pub/process_job.rb
index a79abf5d..af686dbd 100644
--- a/app/jobs/activity_pub/process_job.rb
+++ b/app/jobs/activity_pub/process_job.rb
@@ -94,7 +94,7 @@ class ActivityPub
         .type_from(original_activity)
         .lock
         .find_or_initialize_by(uri: original_activity[:id], activity_pub: activity_pub, actor: actor).tap do |a|
-          a.lock! if o.persisted?
+          a.lock! if a.persisted?
           a.content = original_activity.dup
           a.content[:object] = object.uri
           a.save!
@@ -107,7 +107,7 @@ class ActivityPub
     # @return [Actor]
     def actor
       @actor ||= ::ActivityPub::Actor.lock.find_or_initialize_by(uri: original_activity[:actor]).tap do |a|
-        a.lock! if o.persisted?
+        a.lock! if a.persisted?
 
         unless a.instance
           a.instance = ::ActivityPub::Instance.lock.find_or_create_by(hostname: URI.parse(a.uri).hostname)