Class: Langfuse::BatchWorker

Inherits:
Object
  • Object
show all
Extended by:
T::Sig
Includes:
Sidekiq::Worker
Defined in:
lib/langfuse/batch_worker.rb,
lib/langfuse/batch_worker.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.perform_async(events) ⇒ Object 



16
17
18
19
 
# File 'lib/langfuse/batch_worker.rb', line 16

def self.perform_async(events)
  # When Sidekiq is not available, process synchronously and return result
  new.perform(events)
end

Instance Method Details

#perform(event_hashes) ⇒ Object 



22
23
24
25
 
# File 'lib/langfuse/batch_worker.rb', line 22

def perform(events)
  # Assuming Langfuse.configuration returns a valid config object for ApiClient
  T.unsafe(Langfuse::ApiClient).new(T.unsafe(Langfuse).configuration).ingest(events)
end