parallel ops in dagster

parallel_graph.py

def mutect2_gatk3_variant_calling_parallel_graph(
    normal_bam: Path, tumor_bam: Path, normal_bam_index: Optional[Path] = None, tumor_bam_index: Optional[Path] = None
):
    mutect2_regions = generate_mutect2_regions_op()
    mutect2_part_vcfs = mutect2_regions.map(
        lambda region: mutect2_variant_calling_part_op(
            tumor_bam, normal_bam, region, tumor_bam_index=tumor_bam_index, normal_bam_index=normal_bam_index
        )
    )
    merged_vcf_path = merge_files_op(mutect2_part_vcfs.collect())
    return merged_vcf_path