options_for_fifo

in lib/active_job/queue_adapters/sqs_adapter/params.rb [57:68]

• 9 lines of code
• 3 McCabe index (conditional complexity)

        def options_for_fifo
          options = {}
          options[:message_deduplication_id] =
            Digest::SHA256.hexdigest(ActiveSupport::JSON.dump(deduplication_body))

          message_group_id = @job.message_group_id if @job.respond_to?(:message_group_id)
          message_group_id ||= Aws::ActiveJob::SQS.config.message_group_id_for(@job.queue_name)

          options[:message_group_id] = message_group_id
          options
        end