lib/rocket_job/extensions/aasm.rb in rocketjob-3.0.0.rc5 vs lib/rocket_job/extensions/aasm.rb in rocketjob-3.0.0

@@ -53,5 +53,20 @@
       @global_callbacks = @global_callbacks.dup
     end
   end
 end
 
+# Patch to try and make AASM threadsafe
+AASM::StateMachineStore
+module AASM
+  class StateMachineStore
+    @stores = Concurrent::Map.new
+
+    def self.stores
+      @stores
+    end
+
+    def initialize
+      @machines = Concurrent::Map.new
+    end
+  end
+end