user_stream_job.rb

module Bigquery
  class UserStreamJob < ApplicationJob
    queue_as :default

    def perform(user_id)
      user = User.find_by(id: user_id)
      return if user.blank?

      service = Bigquery::UserService.new
      service.insert_rows(user)
    end
  end
end