close_stale_files

in lib/logstash/outputs/kusto.rb [294:312]

• 15 lines of code
• 2 McCabe index (conditional complexity)

  def close_stale_files
    now = Time.now
    return unless now - @last_stale_cleanup_cycle >= @stale_cleanup_interval

    @logger.debug('Starting stale files cleanup cycle', files: @files)
    inactive_files = @files.select { |path, fd| not fd.active }
    @logger.debug("#{inactive_files.count} stale files found", inactive_files: inactive_files)
    inactive_files.each do |path, fd|
      @logger.info("Closing file #{path}")
      fd.close
      @files.delete(path)

      kusto_send_file(path)
    end
    
    @files.each { |path, fd| fd.active = false }
    @last_stale_cleanup_cycle = now
  end