lib/eventsimple/reactor_worker.rb in eventsimple-1.1.3 vs lib/eventsimple/reactor_worker.rb in eventsimple-1.2.0
- old
+ new
@@ -4,11 +4,13 @@
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
- ApplicationRecord.uncached { GlobalID::Locator.locate event_global_id }
+ 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