fn new_channel_list( num_partitions: usize, ) -> (SenderList, Vec<Option<Receiver<Result<SeriesBatch>>>>)