the-future
class BufferedStreamClient class FollowBufferFlushWorker include Sidekiq::Worker sidekiq_options queue: 'now', retry: false def perform FollowBuffer.new.flush_batch end end end