We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7b628d6 commit 26f84a9Copy full SHA for 26f84a9
test/models/solid_queue/job_test.rb
@@ -68,6 +68,16 @@ class NonOverlappingGroupedJob2 < NonOverlappingJob
68
assert_equal solid_queue_job.scheduled_at, execution.scheduled_at
69
end
70
71
+ test "enqueue jobs within a connected_to block for the primary DB" do
72
+ ShardedRecord.connected_to(role: :writing, shard: :shard_two) do
73
+ ShardedJobResult.create!(value: "in shard two")
74
+ AddToBufferJob.perform_later("enqueued within block")
75
+ end
76
+
77
+ job = SolidQueue::Job.last
78
+ assert_equal "enqueued within block", job.arguments.dig("arguments", 0)
79
80
81
test "enqueue jobs without concurrency controls" do
82
active_job = AddToBufferJob.perform_later(1)
83
assert_nil active_job.concurrency_limit
0 commit comments