Module: PlatformSdk::Observability::Langfuse::SidekiqLifecycle

Defined in:
lib/platform_sdk/observability/langfuse/sidekiq_lifecycle.rb

Class Method Summary collapse

Class Method Details

.install! ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/platform_sdk/observability/langfuse/sidekiq_lifecycle.rb', line 13

def install!
  @mutex.synchronize do
    return if @installed

    @installed = true
    ::Sidekiq.configure_server do |config|
      config.on(:shutdown) do
        PlatformSdk::Observability::Langfuse.configuration&.force_flush_and_shutdown
      end
    end
  end
end

.reset! ⇒ Object 



26
27
28
 
# File 'lib/platform_sdk/observability/langfuse/sidekiq_lifecycle.rb', line 26

def reset!
  @mutex.synchronize { @installed = false }
end