Skip to content
Snippets Groups Projects
Commit c8086739 authored by james94's avatar james94
Browse files

rule name changes

parent fc7d38fa
No related branches found
No related tags found
No related merge requests found
...@@ -7,9 +7,9 @@ cluster: ...@@ -7,9 +7,9 @@ cluster:
--qos={resources.qos} --qos={resources.qos}
--cpus-per-task={threads} --cpus-per-task={threads}
--mem={resources.mem_mb} --mem={resources.mem_mb}
--job-name=GEP.{rule}.{wildcards}.%j --job-name=GEP.{rule}.%j
--output=slurm_logs/{rule}/{wildcards}.%j.out --output=slurm_logs/{rule}/%j.out
--error=slurm_logs/{rule}/{wildcards}.%j.err --error=slurm_logs/{rule}/%j.err
--time={resources.time} --time={resources.time}
......
...@@ -201,9 +201,8 @@ elif set(['ID', 'ASM_LEVEL', 'PRI_asm', 'ALT_asm', 'merylDB', 'merylDB_kmer', 'g ...@@ -201,9 +201,8 @@ elif set(['ID', 'ASM_LEVEL', 'PRI_asm', 'ALT_asm', 'merylDB', 'merylDB_kmer', 'g
dictSamples=samples.T.to_dict('list') dictSamples=samples.T.to_dict('list')
ruleAllQCFiles=[] ruleAllQCFiles=[]
ruleAll=expand(os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_aggregatedResults.tsv"), asmID=list(dictSamples.keys())),\ ruleAll=expand(os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_aggregatedSTATS.tsv"), asmID=list(dictSamples.keys())),\
os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS.tsv"), \ os.path.join(config['Results'],"1_evaluation/finalResults/FINAL_REPORT.pdf")
os.path.join(config['Results'],"1_evaluation/finalResults/FULL_REPORT.pdf")
### DOWNLOAD BUSCO LINEAGE (IF IT DOESN'T ALREADY EXIST) #### ### DOWNLOAD BUSCO LINEAGE (IF IT DOESN'T ALREADY EXIST) ####
...@@ -258,7 +257,7 @@ elif set(['ID', 'ASM_LEVEL', 'PRI_asm', 'ALT_asm', 'merylDB', 'merylDB_kmer', 'g ...@@ -258,7 +257,7 @@ elif set(['ID', 'ASM_LEVEL', 'PRI_asm', 'ALT_asm', 'merylDB', 'merylDB_kmer', 'g
raise ValueError("Error - could not identify lineage please check busco site for a correct prefix") raise ValueError("Error - could not identify lineage please check busco site for a correct prefix")
else: else:
raise ValueError('Sample Sheet for not recognised. Please make sure you are using the correct sample sheet') raise ValueError('Sample Sheet not recognised. Please make sure you are using the correct sample sheet')
......
...@@ -251,7 +251,6 @@ rule merylCount_R1_illumina: ...@@ -251,7 +251,6 @@ rule merylCount_R1_illumina:
os.path.join(workflow.basedir, "envs/MERYL_MERQURY.yaml") os.path.join(workflow.basedir, "envs/MERYL_MERQURY.yaml")
shell: shell:
""" """
export OMP_NUM_THREADS={threads}
(meryl count k={params.kmer} threads={threads} {input.read1} output {output}) &> {log} (meryl count k={params.kmer} threads={threads} {input.read1} output {output}) &> {log}
""" """
...@@ -275,7 +274,6 @@ rule merylCount_R2_illumina: ...@@ -275,7 +274,6 @@ rule merylCount_R2_illumina:
os.path.join(workflow.basedir, "envs/MERYL_MERQURY.yaml") os.path.join(workflow.basedir, "envs/MERYL_MERQURY.yaml")
shell: shell:
""" """
export OMP_NUM_THREADS={threads}
(meryl count k={params.kmer} threads={threads} {input.read2} output {output}) &> {log} (meryl count k={params.kmer} threads={threads} {input.read2} output {output}) &> {log}
""" """
...@@ -306,7 +304,6 @@ rule merylUnion_illumina: ...@@ -306,7 +304,6 @@ rule merylUnion_illumina:
os.path.join(workflow.basedir, "envs/MERYL_MERQURY.yaml") os.path.join(workflow.basedir, "envs/MERYL_MERQURY.yaml")
shell: shell:
""" """
export OMP_NUM_THREADS={threads}
(meryl union-sum {input.read1} {input.read2} output {output}) &> {log} (meryl union-sum {input.read1} {input.read2} output {output}) &> {log}
rm -r {params.removeReadDIR_trimmed} rm -r {params.removeReadDIR_trimmed}
rm -r {params.removeReadDIR_unzipped} rm -r {params.removeReadDIR_unzipped}
......
...@@ -5,24 +5,22 @@ def merylDB(wildcards): ...@@ -5,24 +5,22 @@ def merylDB(wildcards):
return samples.loc[(wildcards.asmID), "merylDB"] return samples.loc[(wildcards.asmID), "merylDB"]
localrules: symlink_UnzippedFastq_R1_HiC, \ localrules: symlink_UnzippedFastq_R1_HiC, \
symlink_UnzippedFastq_R2_HiC, \ symlink_UnzippedFastq_R2_HiC, \
symlink_UnzippedFasta_PRI, \ symlink_UnzippedFasta_PRI, \
symlink_UnzippedFasta_ALT, \ symlink_UnzippedFasta_ALT, \
# symlinkMerylDB, \ KeyResults_GenomescopeProfiles, \
# moveBuscoOutputs, \ KeyResults, \
copyKeyResults_GenomeScope2Profiles, \ Tables_TSV, \
copyKeyResults, \ IndividualResults_md, \
saveConfigurationAndSampleSheet_createComparisonTablesTSV, \ PretextMaps_md, \
IndividualKeyResults_createMD, \ Table_md, \
PretextMaps_createMD, \ Reports_md, \
ComparisonTables_createMD, \ Reports_pdf, \
ReportWithoutComparisonTables_createMD, \ ColouredTable_html, \
ReportWithoutComparisonTables_createPDF, \ HeatmapTable_html, \
ComparisonTablesColoured_createHTML, \ BothTables_pdf, \
ComparisonTables_createPDF, \ ConcatAll_pdfs
ComparisonTablesGradient_createHTML, \
COMBINE_ALL_PDFS
def HiC_R1_gzipped(wildcards): def HiC_R1_gzipped(wildcards):
return yesGzip_HiC_R1.loc[(wildcards.asmID), "HiC_R1"] return yesGzip_HiC_R1.loc[(wildcards.asmID), "HiC_R1"]
...@@ -533,7 +531,7 @@ rule assemblyStats: ...@@ -533,7 +531,7 @@ rule assemblyStats:
rule copyKeyResults_GenomeScope2Profiles: rule KeyResults_GenomescopeProfiles:
input: input:
gscopeSum=os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_summary.txt"), gscopeSum=os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_summary.txt"),
gscopeLog=os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_log_plot.png"), gscopeLog=os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_log_plot.png"),
...@@ -554,7 +552,7 @@ rule copyKeyResults_GenomeScope2Profiles: ...@@ -554,7 +552,7 @@ rule copyKeyResults_GenomeScope2Profiles:
rule copyKeyResults: rule KeyResults:
input: input:
gscopeSum=lambda wildcards: expand(os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_summary.txt"), asmID=wildcards.asmID, kmer=dictSamples[wildcards.asmID][4]), gscopeSum=lambda wildcards: expand(os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_summary.txt"), asmID=wildcards.asmID, kmer=dictSamples[wildcards.asmID][4]),
# gscopeLog=lambda wildcards: expand(os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_log_plot.png"), asmID=wildcards.asmID, kmer=dictSamples[wildcards.asmID][4]), # gscopeLog=lambda wildcards: expand(os.path.join(config['Results'], "1_evaluation/{asmID}/GENOMESCOPE_PROFILES/{asmID}_k{kmer}_log_plot.png"), asmID=wildcards.asmID, kmer=dictSamples[wildcards.asmID][4]),
...@@ -628,7 +626,7 @@ rule copyKeyResults: ...@@ -628,7 +626,7 @@ rule copyKeyResults:
rm {params.rowNames} {params.keyValues} rm {params.rowNames} {params.keyValues}
""" """
rule saveConfigurationAndSampleSheet_createComparisonTablesTSV: rule Tables_TSV:
input: input:
allResults=expand(os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_aggregatedSTATS.tsv"), asmID=list(dictSamples.keys())), allResults=expand(os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_aggregatedSTATS.tsv"), asmID=list(dictSamples.keys())),
sampleSheet= config['samplesTSV'], sampleSheet= config['samplesTSV'],
...@@ -650,7 +648,7 @@ rule saveConfigurationAndSampleSheet_createComparisonTablesTSV: ...@@ -650,7 +648,7 @@ rule saveConfigurationAndSampleSheet_createComparisonTablesTSV:
sed -i 's/,//g' {output.results} sed -i 's/,//g' {output.results}
""" """
rule IndividualKeyResults_createMD: rule IndividualResults_md:
input: input:
os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_aggregatedSTATS.tsv"), os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_aggregatedSTATS.tsv"),
lambda wildcards: expand(os.path.join(config['Results'], "1_evaluation/{asmID}/KEY_RESULTS/{asmID}_k{kmer}_log_plot.png"),asmID=wildcards.asmID, kmer=dictSamples[wildcards.asmID][4]), lambda wildcards: expand(os.path.join(config['Results'], "1_evaluation/{asmID}/KEY_RESULTS/{asmID}_k{kmer}_log_plot.png"),asmID=wildcards.asmID, kmer=dictSamples[wildcards.asmID][4]),
...@@ -673,7 +671,7 @@ rule IndividualKeyResults_createMD: ...@@ -673,7 +671,7 @@ rule IndividualKeyResults_createMD:
rule PretextMaps_createMD: rule PretextMaps_md:
input: input:
PretextMap=os.path.join(config['Results'], "1_evaluation/{asmID}/HiC_MAPS/{asmID}.HiC.COMBINED.FILTERED_FullMap.png") PretextMap=os.path.join(config['Results'], "1_evaluation/{asmID}/HiC_MAPS/{asmID}.HiC.COMBINED.FILTERED_FullMap.png")
output: output:
...@@ -686,7 +684,7 @@ rule PretextMaps_createMD: ...@@ -686,7 +684,7 @@ rule PretextMaps_createMD:
script: script:
os.path.join(workflow.basedir, "scripts/report/pretextMapsToMarkdown.py") os.path.join(workflow.basedir, "scripts/report/pretextMapsToMarkdown.py")
rule ComparisonTables_createMD: rule Table_md:
input: input:
results=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS.tsv") results=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS.tsv")
output: output:
...@@ -697,7 +695,7 @@ rule ComparisonTables_createMD: ...@@ -697,7 +695,7 @@ rule ComparisonTables_createMD:
script: script:
os.path.join(workflow.basedir, "scripts/report/addFullTableForReport.py") os.path.join(workflow.basedir, "scripts/report/addFullTableForReport.py")
rule ComparisonTablesColoured_createHTML: rule ColouredTable_html:
input: input:
os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_roundedMB.tsv") os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_roundedMB.tsv")
params: params:
...@@ -714,7 +712,7 @@ rule ComparisonTablesColoured_createHTML: ...@@ -714,7 +712,7 @@ rule ComparisonTablesColoured_createHTML:
script: script:
os.path.join(workflow.basedir, "scripts/compare_results/fullTable_heatmap_external.R") os.path.join(workflow.basedir, "scripts/compare_results/fullTable_heatmap_external.R")
rule ComparisonTablesGradient_createHTML: rule HeatmapTable_html:
input: input:
os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_roundedMB.tsv") os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_roundedMB.tsv")
params: params:
...@@ -731,7 +729,7 @@ rule ComparisonTablesGradient_createHTML: ...@@ -731,7 +729,7 @@ rule ComparisonTablesGradient_createHTML:
script: script:
os.path.join(workflow.basedir, "scripts/compare_results/fullTable_heatmap_internalComparison.R") os.path.join(workflow.basedir, "scripts/compare_results/fullTable_heatmap_internalComparison.R")
rule ComparisonTables_createPDF: rule BothTables_pdf:
input: input:
coloured=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_COLOURED.html"), coloured=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_COLOURED.html"),
gradient=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_GRADIENT.html") gradient=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_GRADIENT.html")
...@@ -756,7 +754,7 @@ rule ComparisonTables_createPDF: ...@@ -756,7 +754,7 @@ rule ComparisonTables_createPDF:
-o {output.gradient} --pdf-engine=wkhtmltopdf --pdf-engine-opt="-O" --pdf-engine-opt="Landscape" {input.gradient}) &>> {log} -o {output.gradient} --pdf-engine=wkhtmltopdf --pdf-engine-opt="-O" --pdf-engine-opt="Landscape" {input.gradient}) &>> {log}
""" """
rule ReportWithoutComparisonTables_createMD: rule Reports_md:
input: input:
indivMD=[expand(os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_k{kmer}_markdownForReport.md"), asmID=key, kmer=value5) for key, [value1, value2, value3, value4, value5, value6, value7, value8, value9, value10, value11, value12, value13, value14, value15, value16] in dictSamples.items()], indivMD=[expand(os.path.join(config['Results'],"1_evaluation/{asmID}/KEY_RESULTS/{asmID}_k{kmer}_markdownForReport.md"), asmID=key, kmer=value5) for key, [value1, value2, value3, value4, value5, value6, value7, value8, value9, value10, value11, value12, value13, value14, value15, value16] in dictSamples.items()],
landingPage=os.path.join(workflow.basedir, "scripts/report/reportLandingPage.md"), landingPage=os.path.join(workflow.basedir, "scripts/report/reportLandingPage.md"),
...@@ -775,7 +773,7 @@ rule ReportWithoutComparisonTables_createMD: ...@@ -775,7 +773,7 @@ rule ReportWithoutComparisonTables_createMD:
# cat {input.landingPageTABLE} {input.endTableMD} >> {output.endTableMD} # cat {input.landingPageTABLE} {input.endTableMD} >> {output.endTableMD}
rule ReportWithoutComparisonTables_createPDF: rule Reports_pdf:
input: input:
md_report=os.path.join(config['Results'],"1_evaluation/finalResults/ALL_individual_REPORTS.md"), md_report=os.path.join(config['Results'],"1_evaluation/finalResults/ALL_individual_REPORTS.md"),
# md_comparison_table=os.path.join(config['Results'],"1_evaluation/finalResults/FullTableMarkdown_wPreamble.md") # md_comparison_table=os.path.join(config['Results'],"1_evaluation/finalResults/FullTableMarkdown_wPreamble.md")
...@@ -797,7 +795,7 @@ rule ReportWithoutComparisonTables_createPDF: ...@@ -797,7 +795,7 @@ rule ReportWithoutComparisonTables_createPDF:
""" """
# (pandoc -o {output.pdf_comparison_table} {input.md_comparison_table} --pdf-engine=tectonic) &>> {log} # (pandoc -o {output.pdf_comparison_table} {input.md_comparison_table} --pdf-engine=tectonic) &>> {log}
rule COMBINE_ALL_PDFS: rule ConcatAll_pdfs:
input: input:
pdf_report=os.path.join(config['Results'],"1_evaluation/finalResults/ALL_individual_REPORTS.pdf"), pdf_report=os.path.join(config['Results'],"1_evaluation/finalResults/ALL_individual_REPORTS.pdf"),
coloured=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_COLOURED.pdf"), coloured=os.path.join(config['Results'],"1_evaluation/finalResults/TABLE_OF_RESULTS_COLOURED.pdf"),
...@@ -807,7 +805,7 @@ rule COMBINE_ALL_PDFS: ...@@ -807,7 +805,7 @@ rule COMBINE_ALL_PDFS:
pdf_report=os.path.join(config['Results'],"1_evaluation/finalResults/FINAL_REPORT.pdf"), pdf_report=os.path.join(config['Results'],"1_evaluation/finalResults/FINAL_REPORT.pdf"),
# pdf_comparison_table=os.path.join(config['Results'],"1_evaluation/finalResults/FULL_TABLE_PDF.pdf") # pdf_comparison_table=os.path.join(config['Results'],"1_evaluation/finalResults/FULL_TABLE_PDF.pdf")
log: log:
os.path.join(config['Results'], "1_evaluation/logs/COMBINE_ALL_PDFS.log") os.path.join(config['Results'], "1_evaluation/logs/ConcatAll_pdfs.log")
conda: conda:
os.path.join(workflow.basedir, "envs/AUXILIARY_PYTHON_SCRIPTS.yaml") os.path.join(workflow.basedir, "envs/AUXILIARY_PYTHON_SCRIPTS.yaml")
# threads: # threads:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment