6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
# File 'lib/switchman_inst_jobs/switchman/database_server.rb', line 6
def delayed_jobs_shard(shard = nil)
return shard if config[:delayed_jobs_shard] == "self"
dj_shard =
config[:delayed_jobs_shard] &&
::Switchman::Shard.lookup(config[:delayed_jobs_shard])
if shard&.default?
dj_shard ||= ::Switchman::Shard.delayed_jobs_shards.find(&:database_server)
dj_shard ||= shard
end
dj_shard ||= SwitchmanInstJobs.delayed_jobs_shard_fallback&.call(self, shard)
dj_shard || ::Switchman::Shard.default.delayed_jobs_shard
end
|