Skip to content

Commit

Permalink
Lock down the ADAM version.
Browse files Browse the repository at this point in the history
  • Loading branch information
fnothaft committed Jan 15, 2016
1 parent f53852b commit 50f6d08
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions src/toil_scripts/adam_pipeline/spark_toil_script.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@

#!/usr/bin/env python2.7
"""
UCSC Computational Genomics Lab RNA-seq Pipeline
Expand Down Expand Up @@ -109,7 +110,7 @@ def adam_convert(job, masterIP, inFile, snpFile, inputs):
adamFile = ".".join(os.path.splitext(inFile)[0])+".adam"

check_call(["docker", "run", "--net=host",
"computationalgenomicslab/adam",
"computationalgenomicslab/adam:cd6ef41",
"--master", "spark://"+masterIP+":"+SPARK_MASTER_PORT,
"--conf", "spark.hadoop.fs.default.name=hdfs://%s:%s" % (masterIP, HDFS_MASTER_PORT),
"--", "transform",
Expand All @@ -118,7 +119,7 @@ def adam_convert(job, masterIP, inFile, snpFile, inputs):
adamSnpFile = ".".join(os.path.splitext(snpFile)[0])+".var.adam"

check_call(["docker", "run", "--net=host",
"computationalgenomicslab/adam",
"computationalgenomicslab/adam:cd6ef41",
"--master", "spark://"+masterIP+":"+SPARK_MASTER_PORT,
"--conf", "spark.hadoop.fs.default.name=hdfs://%s:%s" % (masterIP, HDFS_MASTER_PORT),
"--", "vcf2adam",
Expand All @@ -141,7 +142,7 @@ def adam_transform(job, masterIP, inFile, snpFile, inputs):
outFile = ".".join(os.path.splitext(inFile)[0])+".processed.bam"

check_call(["docker", "run", "--net=host",
"computationalgenomicslab/adam",
"computationalgenomicslab/adam:cd6ef41",
"--master", "spark://"+masterIP+":"+SPARK_MASTER_PORT,
"--conf", "spark.driver.memory=%s" % inputs["driverMemory"],
"--conf", "spark.executor.memory=%s" % inputs["executorMemory"],
Expand All @@ -151,7 +152,7 @@ def adam_transform(job, masterIP, inFile, snpFile, inputs):
"-mark_duplicate_reads"])

check_call(["docker", "run", "--net=host",
"computationalgenomicslab/adam",
"computationalgenomicslab/adam:cd6ef41",
"--master", "spark://"+masterIP+":"+SPARK_MASTER_PORT,
"--conf", "spark.driver.memory=%s" % inputs["driverMemory"],
"--conf", "spark.executor.memory=%s" % inputs["executorMemory"],
Expand All @@ -161,7 +162,7 @@ def adam_transform(job, masterIP, inFile, snpFile, inputs):
"-realign_indels"])

check_call(["docker", "run", "--net=host",
"computationalgenomicslab/adam",
"computationalgenomicslab/adam:cd6ef41",
"--master", "spark://"+masterIP+":"+SPARK_MASTER_PORT,
"--conf", "spark.driver.memory=%s" % inputs["driverMemory"],
"--conf", "spark.executor.memory=%s" % inputs["executorMemory"],
Expand All @@ -172,7 +173,7 @@ def adam_transform(job, masterIP, inFile, snpFile, inputs):
"-known_snps", snpFile])

check_call(["docker", "run", "--net=host",
"computationalgenomicslab/adam",
"computationalgenomicslab/adam:cd6ef41",
"--master", "spark://"+masterIP+":"+SPARK_MASTER_PORT,
"--conf", "spark.driver.memory=%s" % inputs["driverMemory"],
"--conf", "spark.executor.memory=%s" % inputs["executorMemory"],
Expand Down

0 comments on commit 50f6d08

Please sign in to comment.