From 150406472170fe15dd22cbe5eca48fc48345941d Mon Sep 17 00:00:00 2001 From: amirhasanzadeh Date: Wed, 24 Sep 2025 15:22:34 +0330 Subject: [PATCH] fix: adjust indentation in 'lock_message_for_processing' method --- app/lib/worker/jobs/process_queued_messages_job.rb | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/app/lib/worker/jobs/process_queued_messages_job.rb b/app/lib/worker/jobs/process_queued_messages_job.rb index 9c0995229..f78a90040 100644 --- a/app/lib/worker/jobs/process_queued_messages_job.rb +++ b/app/lib/worker/jobs/process_queued_messages_job.rb @@ -46,12 +46,12 @@ def local_ip?(ip) # @return [void] def lock_message_for_processing QueuedMessage.joins(:server) - .where(ip_address_id: [nil, @ip_addresses]) - .where(locked_by: nil, locked_at: nil) - .ready_with_delayed_retry - .order("servers.priority DESC, queued_messages.id ASC") - .limit(1) - .update_all(locked_by: @locker, locked_at: @lock_time) + .where(ip_address_id: [nil, @ip_addresses]) + .where(locked_by: nil, locked_at: nil) + .ready_with_delayed_retry + .order("servers.priority DESC, queued_messages.id ASC") + .limit(1) + .update_all(locked_by: @locker, locked_at: @lock_time) end # Get a full list of all messages which we can process (i.e. those which have just