Commit 6dbf885c authored by Lukas Jelonek's avatar Lukas Jelonek
Browse files

Add chunkprocessing via drmaa

parent 8487d7da
...@@ -17,8 +17,9 @@ def flatten(d, parent_key='', sep='_'): ...@@ -17,8 +17,9 @@ def flatten(d, parent_key='', sep='_'):
analysis_template = Template (''' analysis_template = Template ('''
process ${id} { process ${id} {
executor 'drmaa'
input: input:
file fasta from for_${id} file fasta from for_${id}.splitFasta(by:100, file:'input')
output: output:
file "$${fasta}.${id}.results" into ${id}_results file "$${fasta}.${id}.results" into ${id}_results
...@@ -74,7 +75,7 @@ process convert_${id}_to_json { ...@@ -74,7 +75,7 @@ process convert_${id}_to_json {
""" """
} }
''') ''')
input_template = Template(''' file ${id}_result from ${id}_json''') input_template = Template(''' file ${id}_result from ${id}_json.collect()''')
join_jsons_template = Template(''' join_jsons_template = Template('''
process join_documents { process join_documents {
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment