diff --git a/app/jobs/regular/process_post.rb b/app/jobs/regular/process_post.rb index 8dd7487f369..b13d69d61d8 100644 --- a/app/jobs/regular/process_post.rb +++ b/app/jobs/regular/process_post.rb @@ -7,7 +7,7 @@ module Jobs class ProcessPost < ::Jobs::Base def execute(args) - DistributedMutex.synchronize("process_post_#{args[:post_id]}") do + DistributedMutex.synchronize("process_post_#{args[:post_id]}", validity: 10.minutes) do post = Post.find_by(id: args[:post_id]) # two levels of deletion return unless post.present? && post.topic.present?