code: def find_files(data_path, brokers, minutes, start_time, end_time):
      
      command = find_files_cmd(data_path, minutes, start_time, end_time)
      pool = Pool(len(brokers))
      result = pool.map(
          partial(get_output_lines_from_command, command=command),
          [host for broker, host in brokers])
      return [(broker, host, files)
              for (broker, host), files
              in zip(brokers, result)]
docs: Find all the Kafka log files on the broker that have been modified
      in the speficied time range.
  
      start_time and end_time should be in the format specified
      by TIME_FORMAT_REGEX.
  
      :param data_path: the path to the lof files on the broker
      :type data_path: str
      :param brokers: the brokers
      :type brokers: list of (broker_id, host) pairs
      :param minutes: check the files modified in the last N minutes
      :type minutes: int
      :param start_time: check the files modified after start_time
      :type start_time: str
      :param end_time: check the files modified before end_time
      :type end_time: str
      :returns: the files
      :rtype: list of (broker, host, file_path) tuples