1
1
import logging
2
+ import os
3
+ import posixpath
2
4
import shlex
3
5
import shutil
4
6
import subprocess
9
11
from urlparse import urlparse
10
12
from uuid import uuid4
11
13
12
- import os
13
- import posixpath
14
14
from bd2k .util .iterables import concat
15
15
from boto .s3 .connection import S3Connection , Bucket
16
16
@@ -37,10 +37,13 @@ def setUpClass(cls):
37
37
logging .basicConfig (level = logging .INFO )
38
38
39
39
def setUp (self ):
40
- self . input_dir = urlparse ( 's3://cgl-pipeline-inputs/rnaseq_cgl/ci' )
40
+ # S3 bucket link
41
41
self .output_dir = urlparse ('s3://cgl-driver-projects/test/ci/%s' % uuid4 ())
42
- self .sample = urlparse (self .input_dir .geturl () + '/chr6_sample.tar.gz' )
43
- self .bam_sample = urlparse (self .input_dir .geturl () + '/chr6.test.bam' )
42
+ # URLs to chr6 sample
43
+ self .input_url = urlparse ('http://courtyard.gi.ucsc.edu/~jvivian/toil-rnaseq-inputs/' )
44
+ self .sample = urlparse (os .path .join (self .input_url .geturl (), 'continuous_integration/chr6_paired.tar.gz' ))
45
+ self .bam_sample = urlparse (self .input_url .geturl () + 'continuous_integration/chr6.test.bam' )
46
+ # Command setup
44
47
self .workdir = tempfile .mkdtemp ()
45
48
jobStore = os .getenv ('TOIL_SCRIPTS_TEST_JOBSTORE' , os .path .join (self .workdir , 'jobstore-%s' % uuid4 ()))
46
49
toilOptions = shlex .split (os .environ .get ('TOIL_SCRIPTS_TEST_TOIL_OPTIONS' , '' ))
@@ -88,14 +91,14 @@ def _generate_config(self):
88
91
path = os .path .join (self .workdir , 'config-toil-rnaseq.yaml' )
89
92
with open (path , 'w' ) as f :
90
93
f .write (textwrap .dedent ("""
91
- star-index: {input_dir} /starIndex_chr6.tar.gz
92
- kallisto-index: s3://cgl-pipeline-inputs/rnaseq_cgl/kallisto_hg38.idx
93
- rsem-ref : {input_dir}/rsem_ref_chr6.tar.gz
94
- hera-index: s3://cgl-pipeline-inputs/rnaseq_cgl /hera-index.tar.gz
94
+ star-index: {input_url}/continuous_integration /starIndex_chr6.tar.gz
95
+ rsem-ref: {input_url}/continuous_integration/rsem_ref_chr6.tar.gz
96
+ kallisto-index : {input_url}/kallisto_hg38.idx
97
+ hera-index: {input_url} /hera-index.tar.gz
95
98
output-dir: {output_dir}
96
99
max-sample-size: 2G
97
100
fastqc: true
98
- cutadapt:
101
+ cutadapt: true
99
102
ssec:
100
103
gdc-token:
101
104
wiggle:
@@ -105,7 +108,7 @@ def _generate_config(self):
105
108
bamqc: true
106
109
ci-test: true
107
110
""" [1 :]).format (output_dir = self .output_dir .geturl (),
108
- input_dir = self .input_dir .geturl ()))
111
+ input_url = self .input_url .geturl ()))
109
112
return path
110
113
111
114
def _generate_manifest (self , num_samples = 1 , bam = False ):
0 commit comments