diff options
| author | Peter Amstutz | 2020-04-09 17:48:15 -0400 |
|---|---|---|
| committer | Peter Amstutz | 2020-04-09 17:48:43 -0400 |
| commit | e110b52bae5a4a62ccc53970a7f26899e9debe7e (patch) | |
| tree | 785af7f733b3bd9a2e2247ffc1011b67b1648941 /bh20seqanalyzer | |
| parent | 0670ac0644c1e7366952e254bdee2db62e673275 (diff) | |
| download | bh20-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')
| -rw-r--r-- | bh20seqanalyzer/main.py | 9 |
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) |