enqueue_batch

in lib/active_job/queue_adapters/sqs_adapter.rb [46:62]

• 14 lines of code
• 2 McCabe index (conditional complexity)

      def enqueue_batch(queue_url, chunk)
        entries = chunk.map do |job|
          entry = Params.new(job, nil).entry
          entry[:id] = job.job_id
          entry[:delay_seconds] = Params.assured_delay_seconds(job.scheduled_at) if job.scheduled_at
          entry
        end

        send_message_opts = {
          queue_url: queue_url,
          entries: entries
        }

        send_message_batch_result = Aws::ActiveJob::SQS.config.client.send_message_batch(send_message_opts)
        send_message_batch_result.successful.count
      end