code: def mb_filter(fastq, cores):
      ''' Filters umis with non-ACGT bases
      Expects formatted fastq files.
      '''
      filter_mb = partial(umi_filter)
      p = multiprocessing.Pool(cores)
  
      chunks = tz.partition_all(10000, read_fastq(fastq))
      bigchunks = tz.partition_all(cores, chunks)
      for bigchunk in bigchunks:
          for chunk in p.map(filter_mb, list(bigchunk)):
              for read in chunk:
                  sys.stdout.write(readf mb_filter(fastq, cores):
      ''' Filters umis with non-ACGT bases
      Expects formatted fastq files.
      '''
      filter_mb = partial(umi_filter)
      p = multiprocessing.Pool(cores)
  
      chunks = tz.partition_all(10000, read_fastq(fastq))
      bigchunks = tz.partition_all(cores, chunks)
      for bigchunk in bigchunks:
          for chunk in p.map(filter_mb, list(bigchunk)):
              for read in chunk:
                  sys.stdout.write(read)
docs: Filters umis with non-ACGT bases
      Expects formatted fastq files.