parent
84eae6fac9
commit
9972dfae61
32 changed files with 591 additions and 561 deletions
|
@ -125,7 +125,7 @@ module Mastodon::CLI
|
|||
failed = Concurrent::AtomicFixnum.new(0)
|
||||
start_at = Time.now.to_f
|
||||
seed = start ? [start] : Instance.pluck(:domain)
|
||||
blocked_domains = /\.?(#{Regexp.union(domain_block_suspended_domains).source})$/
|
||||
blocked_domains = /\.?(#{DomainBlock.where(severity: 1).pluck(:domain).map { |domain| Regexp.escape(domain) }.join('|')})$/
|
||||
progress = create_progress_bar
|
||||
|
||||
pool = Concurrent::ThreadPoolExecutor.new(min_threads: 0, max_threads: options[:concurrency], idletime: 10, auto_terminate: true, max_queue: 0)
|
||||
|
@ -189,10 +189,6 @@ module Mastodon::CLI
|
|||
|
||||
private
|
||||
|
||||
def domain_block_suspended_domains
|
||||
DomainBlock.suspend.pluck(:domain)
|
||||
end
|
||||
|
||||
def stats_to_summary(stats, processed, failed, start_at)
|
||||
stats.compact!
|
||||
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue