Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 2 additions & 4 deletions modules/msk/generatemutfasta/main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -27,10 +27,8 @@ process GENERATEMUTFASTA {

tar -xzf ${mutalyzer_cache} -C \$(pwd)/mutalyzer_cache

cat <<-END_MUTALYZER_CONFIG > \$(pwd)/config.txt
MUTALYZER_CACHE_DIR = \$(pwd)/mutalyzer_cache/cache
MUTALYZER_FILE_CACHE_ADD = false
END_MUTALYZER_CONFIG
echo MUTALYZER_CACHE_DIR = \$(pwd)/mutalyzer_cache/cache >> \$(pwd)/config.txt
echo MUTALYZER_FILE_CACHE_ADD = false >> \$(pwd)/config.txt

mkdir ${prefix}_out

Expand Down
6 changes: 3 additions & 3 deletions subworkflows/msk/generate_mutated_peptides/main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -74,17 +74,17 @@ workflow GENERATE_MUTATED_PEPTIDES {
}

def createNEOSVInput(sv_bedpe, hla_str) {
sv_bedpe_channel = sv_bedpe
def sv_bedpe_channel = sv_bedpe
.map{
new Tuple(it[0],it)
}

hla_str_channel = hla_str
def hla_str_channel = hla_str
.map{
new Tuple(it[0],it)
}

merged_sv_hla = sv_bedpe_channel
def merged_sv_hla = sv_bedpe_channel
.join(hla_str_channel, by:0)
.map{
new Tuple(it[1][0], it[1][1], it[2][1])
Expand Down
10 changes: 5 additions & 5 deletions subworkflows/msk/netmhcstabandpan/main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -48,27 +48,27 @@ workflow NETMHCSTABANDPAN {
}

def createNETMHCInput(fastas_and_hla, sv_fastas) {
fastas_and_hla_channel = fastas_and_hla
def fastas_and_hla_channel = fastas_and_hla
.map{
new Tuple(it[0],it)
}

sv_fastas_channel = sv_fastas
def sv_fastas_channel = sv_fastas
.map{
new Tuple(it[0],it)
}

merged_mut = fastas_and_hla_channel
def merged_mut = fastas_and_hla_channel
.join(sv_fastas_channel, by:0)
.map({
new Tuple(it[1][0], it[1][1], it[2][1], it[1][3], "MUT")
})

merged_wt = fastas_and_hla_channel
def merged_wt = fastas_and_hla_channel
.join(sv_fastas_channel, by:0)
.map({
new Tuple(it[1][0], it[1][2], it[2][2], it[1][3], "WT")
})
merged = merged_mut.mix(merged_wt)
def merged = merged_mut.mix(merged_wt)
return merged
}
8 changes: 4 additions & 4 deletions subworkflows/msk/phylowgs/main.nf
Original file line number Diff line number Diff line change
Expand Up @@ -50,17 +50,17 @@ workflow PHYLOWGS {
}

def join_maf_with_cnv(maf,cnv) {
maf_channel = maf
def maf_channel = maf
.map{
new Tuple(it[0].id,it)
}
cnv_channel = cnv
def cnv_channel = cnv
.map{
new Tuple(it[0].id,it)
}
mergedWithKey = maf_channel
def mergedWithKey = maf_channel
.join(cnv_channel)
merged = mergedWithKey
def merged = mergedWithKey
.map{
new Tuple(it[1][0],it[1][1],it[2][1])
}
Expand Down