File tree Expand file tree Collapse file tree 2 files changed +10
-0
lines changed
lib/async/job/adapter/active_job
test/async/job/adapter/active_job Expand file tree Collapse file tree 2 files changed +10
-0
lines changed Original file line number Diff line number Diff line change 6
6
require "async/job"
7
7
require "async/job/processor/inline"
8
8
9
+ # For `config.active_support.isolation_level`.
10
+ require "active_support/railtie"
11
+
9
12
require_relative "thread_local_dispatcher"
10
13
11
14
module Async
@@ -65,6 +68,9 @@ def start(name = "default")
65
68
end
66
69
67
70
config . async_job = self
71
+
72
+ # Ensure we have per-fiber isolation:
73
+ config . active_support . isolation_level = :fiber
68
74
end
69
75
end
70
76
end
Original file line number Diff line number Diff line change @@ -27,6 +27,10 @@ def perform(*arguments, **options)
27
27
expect ( queue . server ) . to be_a ( Async ::Job ::Processor ::Inline )
28
28
end
29
29
30
+ it "defaults to per-fiber isolation" do
31
+ expect ( subject . config . active_support . isolation_level ) . to be == :fiber
32
+ end
33
+
30
34
with "#define_queue" do
31
35
it "can define a queue with name conversion" do
32
36
block = proc { "test definition" }
You can’t perform that action at this time.
0 commit comments