flush_pending_files

in lib/logstash/outputs/kusto.rb [278:291]

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

  def flush_pending_files
    @io_mutex.synchronize do
      @logger.debug('Starting flush cycle')

      @files.each do |path, fd|
        @logger.debug('Flushing file', path: path, fd: fd)
        fd.flush
      end
    end
  rescue Exception => e
    
    @logger.error('Exception flushing files', exception: e.message, backtrace: e.backtrace)
  end