delayer_high_water_marker.rb

Plugin.create :delayer_high_water_marker

Delayer.default.instance_eval do
  alias run_once_dhwm run_once
  def run_once(...)
    s1 = size_norec
    res = run_once_dhwm(...)
    s2 = size_norec
   
    warn "delayer tasks #{s1} -> #{s2}"
    
    res
  end

  def size_norec
    size = 0
    node = @bucket.first
    while node
      size += 1
      node = node.next
    end
    size
  end
end