Sha256: e7fc67016014ae5c4e314e8c73204fb1cc56e20786f568c25b9f64e214a8fee2
Contents?: true
Size: 649 Bytes
Versions: 16
Compression:
Stored size: 649 Bytes
Contents
# frozen_string_literal: true # legacy worker for backwards compatibility when upgrading from Eventsimple <= 1.0.0 module Eventsimple class ReactorWorker include Sidekiq::Worker def perform(event_global_id, reactor_class) gid = GlobalID.parse(event_global_id) event = Retriable.with_context(:reactor) do gid.model_class.uncached { GlobalID::Locator.locate event_global_id } end rescue ActiveRecord::RecordNotFound Rails.logger.error("Event #{event_global_id} not found for reactor: #{reactor_class}") else reactor = reactor_class.constantize reactor.new.call(event) end end end
Version data entries
16 entries across 16 versions & 1 rubygems