in src/train.py [0:0]
def valid_input_fn(hvd, mpi=False): if mpi: return _input(args.epochs, args.batch_size, None, 'valid', hvd) else: return _input(args.epochs, args.batch_size, args.valid, 'valid')