Class: LlmLogs::Batch::FlushJob

Inherits:

ActiveJob::Base

• Object
• ActiveJob::Base
• LlmLogs::Batch::FlushJob

Defined in:

app/jobs/llm_logs/batch/flush_job.rb

Instance Method Summary

• #perform(purpose) ⇒ Object

Instance Method Details

#perform(purpose) ⇒ Object

# File 'app/jobs/llm_logs/batch/flush_job.rb', line 6

def perform(purpose)
  models = LlmLogs::BatchRequest.pending.where(purpose: purpose).distinct.pluck(:model)
  models.each { |model| LlmLogs::Batch.submit_pending(purpose: purpose, model: model) }
end