ce579cf021ca1ee0705bd9484aae55e0d110d0e7,cnvlib/commands.py,,batch_make_reference,#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#,123

Before Change

        antitarget_fnames = []
        // Run coverage on all normals
        pool = parallel.pick_pool(processes)
        for nbam in normal_bams:
            sample_id = core.fbase(nbam)
            sample_pfx = os.path.join(output_dir, sample_id)
            tgt_fname = sample_pfx + ".targetcoverage.cnn"
            pool.apply_async(batch_write_coverage,
                             (target_bed, nbam, tgt_fname, by_count))
            target_fnames.append(tgt_fname)
            anti_fname = sample_pfx + ".antitargetcoverage.cnn"
            pool.apply_async(batch_write_coverage,
                             (antitarget_bed, nbam, anti_fname, by_count))
            antitarget_fnames.append(anti_fname)
        pool.close()
        pool.join()
        // Build reference from *.cnn
        ref_arr = do_reference(target_fnames, antitarget_fnames, fasta,

After Change

                                by_count))

        target_fnames = [tf.result() for tf in tgt_futures]
        antitarget_fnames = [af.result() for af in anti_futures]
        // Build reference from *.cnn
        ref_arr = do_reference(target_fnames, antitarget_fnames, fasta,
                               male_reference, do_gc=True,

Instances