def METHOD_NAME():
    for path in paths:
        # if torch.cuda.is_available():print_rank_0(f"Start reading {path}")
        with open(path) as file:
            if self.split_row:
                for row in file:
                    task_queue.put(row)
            else:
                items = json.load(file)
                for item in items["RECORDS"]:
                    task_queue.put(item)
    # if torch.cuda.is_available():print_rank_0("Read input complete")
    for i in range(len(processes)):
        task_queue.put('STOP')