aboutsummaryrefslogtreecommitdiff
path: root/bh20seqanalyzer/main.py
diff options
context:
space:
mode:
authorPeter Amstutz2020-04-09 17:48:15 -0400
committerPeter Amstutz2020-04-09 17:48:43 -0400
commite110b52bae5a4a62ccc53970a7f26899e9debe7e (patch)
tree785af7f733b3bd9a2e2247ffc1011b67b1648941 /bh20seqanalyzer/main.py
parent0670ac0644c1e7366952e254bdee2db62e673275 (diff)
downloadbh20-seq-resource-e110b52bae5a4a62ccc53970a7f26899e9debe7e.tar.gz
bh20-seq-resource-e110b52bae5a4a62ccc53970a7f26899e9debe7e.tar.lz
bh20-seq-resource-e110b52bae5a4a62ccc53970a7f26899e9debe7e.zip
Propagate metadata to pangenome so it can be merged by workflow
Diffstat (limited to 'bh20seqanalyzer/main.py')
-rw-r--r--bh20seqanalyzer/main.py9
1 files changed, 8 insertions, 1 deletions
diff --git a/bh20seqanalyzer/main.py b/bh20seqanalyzer/main.py
index 1a8965b..2030c1e 100644
--- a/bh20seqanalyzer/main.py
+++ b/bh20seqanalyzer/main.py
@@ -110,13 +110,20 @@ def start_pangenome_analysis(api,
validated_project):
validated = arvados.util.list_all(api.collections().list, filters=[["owner_uuid", "=", validated_project]])
inputobj = {
- "inputReads": []
+ "inputReads": [],
+ "metadata": [],
+ "subjects": []
}
for v in validated:
inputobj["inputReads"].append({
"class": "File",
"location": "keep:%s/sequence.fasta" % v["portable_data_hash"]
})
+ inputobj["metadata"].append({
+ "class": "File",
+ "location": "keep:%s/metadata.yaml" % v["portable_data_hash"]
+ })
+ inputobj["subjects"].append("keep:%s/sequence.fasta" % v["portable_data_hash"])
run_workflow(api, analysis_project, pangenome_workflow_uuid, "Pangenome analysis", inputobj)