Auto pep8'd all python code

workflow/scripts/extractRefData.py

@@ -5,15 +5,18 @@ import pandas as pd
 import warnings
 warnings.simplefilter(action='ignore', category=FutureWarning)
 
+
 def get_args():
     parser = argparse.ArgumentParser()
-    parser.add_argument('-r', '--returnParam',help="The parameter to return (URL or MD5).",required=True)
+    parser.add_argument('-r', '--returnParam',
+                        help="The parameter to return (URL or MD5).", required=True)
     args = parser.parse_args()
     return args
 
+
 def main():
     args = get_args()
-    refQuery=pd.read_json("refQuery.json")
+    refQuery = pd.read_json("refQuery.json")
     if refQuery["File_URL"].count() == 1:
         if args.returnParam == "URL":
             print(refQuery["File_URL"].values[0])
@@ -23,7 +26,8 @@ def main():
             print(refQuery["File_MD5"].values[0])
     else:
         raise Exception("Multple references found: \n%s" %
-            refQuery["RID"])
+                        refQuery["RID"])
+
 
 if __name__ == '__main__':
     main()

workflow/scripts/parseMeta.py

@@ -5,52 +5,61 @@ import pandas as pd
 import warnings
 warnings.simplefilter(action='ignore', category=FutureWarning)
 
+
 def get_args():
     parser = argparse.ArgumentParser()
-    parser.add_argument('-r', '--repRID',help="The replicate RID.",required=True)
-    parser.add_argument('-m', '--metaFile',help="The metadata file to extract.",required=True)
-    parser.add_argument('-p', '--parameter',help="The parameter to extract.",required=True)
+    parser.add_argument(
+        '-r', '--repRID', help="The replicate RID.", required=True)
+    parser.add_argument('-m', '--metaFile',
+                        help="The metadata file to extract.", required=True)
+    parser.add_argument('-p', '--parameter',
+                        help="The parameter to extract.", required=True)
     args = parser.parse_args()
     return args
 
 
 def main():
     args = get_args()
-    metaFile = pd.read_csv(args.metaFile,sep=",",header=0)
+    metaFile = pd.read_csv(args.metaFile, sep=",", header=0)
 
     # Check replicate RID metadata from 'File.csv'
     if (args.parameter == "repRID"):
         if (len(metaFile.Replicate_RID.unique()) > 1):
-            print("There are multiple replicate RID's in the metadata: " + " ".join(metaFile.Replicate_RID.unique()))
+            print("There are multiple replicate RID's in the metadata: " +
+                  " ".join(metaFile.Replicate_RID.unique()))
             exit(1)
         if not (metaFile.Replicate_RID.unique() == args.repRID):
-            print("Replicate RID in metadata does not match run parameters: " + metaFile.Replicate_RID.unique() + " vs " + args.repRID)
+            print("Replicate RID in metadata does not match run parameters: " +
+                  metaFile.Replicate_RID.unique() + " vs " + args.repRID)
             exit(1)
         else:
-            rep=metaFile["Replicate_RID"].unique()[0]
+            rep = metaFile["Replicate_RID"].unique()[0]
             print(rep)
         if (len(metaFile[metaFile["File_Type"] == "FastQ"]) > 2):
-            print("There are more then 2 fastq's in the metadata: " + " ".join(metaFile[metaFile["File_Type"] == "FastQ"].RID))
+            print("There are more then 2 fastq's in the metadata: " +
+                  " ".join(metaFile[metaFile["File_Type"] == "FastQ"].RID))
             exit(1)
 
     # Check experiment RID metadata from 'Experiment.csv'
     if (args.parameter == "expRID"):
         if (len(metaFile.Experiment_RID.unique()) > 1):
-            print("There are multiple experoment RID's in the metadata: " + " ".join(metaFile.Experiment_RID.unique()))
+            print("There are multiple experoment RID's in the metadata: " +
+                  " ".join(metaFile.Experiment_RID.unique()))
             exit(1)
         else:
-            exp=metaFile["Experiment_RID"].unique()[0]
+            exp = metaFile["Experiment_RID"].unique()[0]
             print(exp)
 
     # Check study RID metadata from 'Experiment.csv'
     if (args.parameter == "studyRID"):
         if (len(metaFile.Study_RID.unique()) > 1):
-            print("There are multiple study RID's in the metadata: " + " ".join(metaFile.Study_RID.unique()))
+            print("There are multiple study RID's in the metadata: " +
+                  " ".join(metaFile.Study_RID.unique()))
             exit(1)
         else:
-            study=metaFile["Study_RID"].unique()[0]
+            study = metaFile["Study_RID"].unique()[0]
             print(study)
-    
+
     # Get endedness metadata from 'Experiment Settings.csv'
     if (args.parameter == "endsMeta"):
         if (metaFile.Paired_End.unique() == "Single End"):
@@ -60,7 +69,7 @@ def main():
         else:
             endsMeta = "uk"
         print(endsMeta)
-    
+
     # Manually get endness count from 'File.csv'
     if (args.parameter == "endsManual"):
         if (len(metaFile[metaFile["File_Type"] == "FastQ"]) == 1):
@@ -68,7 +77,7 @@ def main():
         elif (len(metaFile[metaFile["File_Type"] == "FastQ"]) == 2):
             endsManual = "pe"
         print(endsManual)
-    
+
     # Get strandedness metadata from 'Experiment Settings.csv'
     if (args.parameter == "stranded"):
         if (metaFile.Has_Strand_Specific_Information.unique() == "yes"):
@@ -76,10 +85,11 @@ def main():
         elif (metaFile.Has_Strand_Specific_Information.unique() == "no"):
             stranded = "unstranded"
         else:
-            print("Stranded metadata not match expected options: " + metaFile.Has_Strand_Specific_Information.unique())
+            print("Stranded metadata not match expected options: " +
+                  metaFile.Has_Strand_Specific_Information.unique())
             exit(1)
         print(stranded)
-    
+
     # Get spike-in metadata from 'Experiment Settings.csv'
     if (args.parameter == "spike"):
         if (metaFile.Used_Spike_Ins.unique() == "yes"):
@@ -87,7 +97,8 @@ def main():
         elif (metaFile.Used_Spike_Ins.unique() == "no"):
             spike = "no"
         else:
-            print("Spike-ins metadata not match expected options: " + metaFile.Used_Spike_Ins.unique())
+            print("Spike-ins metadata not match expected options: " +
+                  metaFile.Used_Spike_Ins.unique())
             exit(1)
         print(spike)
 
@@ -98,7 +109,8 @@ def main():
         elif (metaFile.Species.unique() == "Homo sapiens"):
             species = "Homo sapiens"
         else:
-            print("Species metadata not match expected options: " + metaFile.Species.unique())
+            print("Species metadata not match expected options: " +
+                  metaFile.Species.unique())
             exit(1)
         print(species)
 
@@ -107,5 +119,6 @@ def main():
         readLength = metaFile.Read_Length.unique()
         print(str(readLength).strip('[]'))
 
+
 if __name__ == '__main__':
     main()

workflow/scripts/splitStudy.py

@@ -5,20 +5,25 @@ import pandas as pd
 import warnings
 warnings.simplefilter(action='ignore', category=FutureWarning)
 
+
 def get_args():
     parser = argparse.ArgumentParser()
-    parser.add_argument('-s', '--studyRID',help="The study RID.",required=True)
+    parser.add_argument('-s', '--studyRID',
+                        help="The study RID.", required=True)
     args = parser.parse_args()
     return args
 
+
 def main():
     args = get_args()
-    studyRID=pd.read_json(args.studyRID+"_studyRID.json")
+    studyRID = pd.read_json(args.studyRID+"_studyRID.json")
     if studyRID["RID"].count() > 0:
-        studyRID["RID"].to_csv(args.studyRID+"_studyRID.csv",header=False,index=False)
+        studyRID["RID"].to_csv(
+            args.studyRID+"_studyRID.csv", header=False, index=False)
     else:
         raise Exception("No associated replicates found: %s" %
-            studyRID)
+                        studyRID)
+
 
 if __name__ == '__main__':
     main()

workflow/scripts/tinHist.py

@@ -6,38 +6,47 @@ import numpy as np
 import warnings
 warnings.simplefilter(action='ignore', category=FutureWarning)
 
+
 def get_args():
     parser = argparse.ArgumentParser()
-    parser.add_argument('-r', '--repRID',help="The replicate RID.",required=True)
+    parser.add_argument(
+        '-r', '--repRID', help="The replicate RID.", required=True)
     args = parser.parse_args()
     return args
 
+
 def main():
     args = get_args()
-    tin = pd.read_csv(args.repRID + '.sorted.deduped.tin.xls',sep="\t",header=0)
-    
-    hist = pd.cut(tin['TIN'],bins=pd.interval_range(start=0,freq=10,end=100,closed='right')).value_counts(sort=False)
+    tin = pd.read_csv(args.repRID + '.sorted.deduped.tin.xls',
+                      sep="\t", header=0)
+
+    hist = pd.cut(tin['TIN'], bins=pd.interval_range(
+        start=0, freq=10, end=100, closed='right')).value_counts(sort=False)
     labels = ["{0} - {1}".format(i, i + 9) for i in range(1, 100, 10)]
     #labels[0] = '0 - 10'
-    binned = tin.assign(Bins=lambda x: pd.cut(tin['TIN'],range(0,105,10),labels=labels,include_lowest=False,right=True))
-    binned['chrom'] = binned['chrom'] = binned['chrom'].replace('chr1','chr01')
-    binned['chrom'] = binned['chrom'].replace('chr2','chr02')
-    binned['chrom'] = binned['chrom'].replace('chr3','chr03')
-    binned['chrom'] = binned['chrom'].replace('chr4','chr04')
-    binned['chrom'] = binned['chrom'].replace('chr5','chr05')
-    binned['chrom'] = binned['chrom'].replace('chr6','chr06')
-    binned['chrom'] = binned['chrom'].replace('chr7','chr07')
-    binned['chrom'] = binned['chrom'].replace('chr8','chr08')
-    binned['chrom'] = binned['chrom'].replace('chr9','chr09')
-    hist = pd.pivot_table(binned, values='geneID', index = 'Bins', columns = 'chrom', aggfunc=np.size)
+    binned = tin.assign(Bins=lambda x: pd.cut(tin['TIN'], range(
+        0, 105, 10), labels=labels, include_lowest=False, right=True))
+    binned['chrom'] = binned['chrom'] = binned['chrom'].replace(
+        'chr1', 'chr01')
+    binned['chrom'] = binned['chrom'].replace('chr2', 'chr02')
+    binned['chrom'] = binned['chrom'].replace('chr3', 'chr03')
+    binned['chrom'] = binned['chrom'].replace('chr4', 'chr04')
+    binned['chrom'] = binned['chrom'].replace('chr5', 'chr05')
+    binned['chrom'] = binned['chrom'].replace('chr6', 'chr06')
+    binned['chrom'] = binned['chrom'].replace('chr7', 'chr07')
+    binned['chrom'] = binned['chrom'].replace('chr8', 'chr08')
+    binned['chrom'] = binned['chrom'].replace('chr9', 'chr09')
+    hist = pd.pivot_table(binned, values='geneID',
+                          index='Bins', columns='chrom', aggfunc=np.size)
     hist['TOTAL'] = hist.sum(axis=1)
-    hist = hist[['TOTAL'] + [ i for i in hist.columns if i != 'TOTAL']]
+    hist = hist[['TOTAL'] + [i for i in hist.columns if i != 'TOTAL']]
     hist = hist.T.fillna(0.0).astype(int)
     #hist = hist.apply(lambda x: x/x.sum()*100, axis=1)
-    hist.to_csv(args.repRID + '.tin.hist.tsv',sep='\t')
-    medFile = open(args.repRID + '.tin.med.csv',"w")
-    medFile.write(str(round(tin['TIN'][(tin['TIN']!=0)].median(),2)))
+    hist.to_csv(args.repRID + '.tin.hist.tsv', sep='\t')
+    medFile = open(args.repRID + '.tin.med.csv', "w")
+    medFile.write(str(round(tin['TIN'][(tin['TIN'] != 0)].median(), 2)))
     medFile.close()
 
+
 if __name__ == '__main__':
     main()

workflow/scripts/utils.py

 #!/usr/bin/env python3
 
-#
-# * --------------------------------------------------------------------------
-# * Licensed under MIT (https://git.biohpc.swmed.edu/BICF/Astrocyte/chipseq_analysis/LICENSE.md)
-# * --------------------------------------------------------------------------
-#
-
-'''General utilities.'''
-
-
 import shlex
 import logging
 import subprocess
@@ -32,7 +23,8 @@ def run_pipe(steps, outfile=None):
         if n == first_step_n:
             if n == last_step_n and outfile:  # one-step pipeline with outfile
                 with open(outfile, 'w') as fh:
-                    print("one step shlex: %s to file: %s" % (shlex.split(step), outfile))
+                    print("one step shlex: %s to file: %s" %
+                          (shlex.split(step), outfile))
                     p = Popen(shlex.split(step), stdout=fh)
                 break
             print("first step shlex to stdout: %s" % (shlex.split(step)))
@@ -40,12 +32,14 @@ def run_pipe(steps, outfile=None):
             p = Popen(shlex.split(step), stdout=PIPE)
         elif n == last_step_n and outfile:  # only treat the last step specially if you're sending stdout to a file
             with open(outfile, 'w') as fh:
-                print("last step shlex: %s to file: %s" % (shlex.split(step), outfile))
+                print("last step shlex: %s to file: %s" %
+                      (shlex.split(step), outfile))
                 p_last = Popen(shlex.split(step), stdin=p.stdout, stdout=fh)
                 p.stdout.close()
                 p = p_last
         else:  # handles intermediate steps and, in the case of a pipe to stdout, the last step
-            print("intermediate step %d shlex to stdout: %s" % (n, shlex.split(step)))
+            print("intermediate step %d shlex to stdout: %s" %
+                  (n, shlex.split(step)))
             p_next = Popen(shlex.split(step), stdin=p.stdout, stdout=PIPE)
             p.stdout.close()
             p = p_next
@@ -54,7 +48,8 @@ def run_pipe(steps, outfile=None):
 
 
 def block_on(command):
-    process = subprocess.Popen(shlex.split(command), stderr=subprocess.STDOUT, stdout=subprocess.PIPE)
+    process = subprocess.Popen(shlex.split(
+        command), stderr=subprocess.STDOUT, stdout=subprocess.PIPE)
     for line in iter(process.stdout.readline, b''):
         sys.stdout.write(line.decode('utf-8'))
     process.communicate()
@@ -77,7 +72,7 @@ def count_lines(filename):
         "compress",
         "bzip2",
         "gzip"
-        ]
+    ]
     mime_type = mimetypes.guess_type(filename)[1]
     if mime_type in compressed_mimetypes:
         catcommand = 'gzip -dc'
@@ -86,7 +81,7 @@ def count_lines(filename):
     out, err = run_pipe([
         '%s %s' % (catcommand, filename),
         'wc -l'
-        ])
+    ])
     return int(out)
 
 

workflow/tests/test_alignReads.py

@@ -6,18 +6,24 @@ import os
 import utils
 
 data_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-	'/../../'
+    '/../../'
 
 
 @pytest.mark.alignData
 def test_alignData_se():
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.unal.gz'))
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.bam'))
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.bam.bai'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.unal.gz'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.bam'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.bam.bai'))
 
 
 @pytest.mark.alignData
 def test_alignData_pe():
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.pe.unal.gz'))
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.pe.sorted.bam'))
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.pe.sorted.bam.bai'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.pe.unal.gz'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.pe.sorted.bam'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.pe.sorted.bam.bai'))

workflow/tests/test_consistency.py

@@ -6,19 +6,24 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.consistencySE
 def test_consistencySE():
-    assert os.path.exists(os.path.join(test_output_path, 'SE_multiqc_data.json'))
-    assert readAssigned("assignedSE.txt","assignedExpectSE.txt")
+    assert os.path.exists(os.path.join(
+        test_output_path, 'SE_multiqc_data.json'))
+    assert readAssigned("assignedSE.txt", "assignedExpectSE.txt")
+
 
 @pytest.mark.consistencyPE
 def test_consistencyPE():
-    assert os.path.exists(os.path.join(test_output_path, 'PE_multiqc_data.json'))
-    assert readAssigned("assignedPE.txt","assignedExpectPE.txt")
+    assert os.path.exists(os.path.join(
+        test_output_path, 'PE_multiqc_data.json'))
+    assert readAssigned("assignedPE.txt", "assignedExpectPE.txt")
+
 
-def readAssigned(fileAssigned,fileExpectAssigned):
+def readAssigned(fileAssigned, fileExpectAssigned):
     data = False
     assigned = open(fileAssigned, "r")
     expect = open(fileExpectAssigned, "r")

workflow/tests/test_dataQC.py

@@ -6,12 +6,16 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.dataQC
 def test_dataQC():
-    assert os.path.exists(os.path.join(test_output_path, 'Q-Y5F6_1M.se.sorted.deduped.tin.xls'))
-    assert countLines(os.path.join(test_output_path, 'Q-Y5F6_1M.se.sorted.deduped.tin.xls'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Q-Y5F6_1M.se.sorted.deduped.tin.xls'))
+    assert countLines(os.path.join(test_output_path,
+                                   'Q-Y5F6_1M.se.sorted.deduped.tin.xls'))
+
 
 def countLines(fileName):
     data = False

workflow/tests/test_dedupReads.py

@@ -6,16 +6,24 @@ import os
 import utils
 
 data_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-	'/../../'
+    '/../../'
 
 
 @pytest.mark.dedupData
 def test_dedupData():
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.bam'))
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.bam.bai'))
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr8.bam'))
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr8.bam.bai'))
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr4.bam'))
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr4.bam.bai'))
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chrY.bam'))
-    assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chrY.bam.bai'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.bam'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.bam.bai'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr8.bam'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr8.bam.bai'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr4.bam'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chr4.bam.bai'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chrY.bam'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.sorted.deduped.chrY.bam.bai'))

workflow/tests/test_downsampleData.py

@@ -6,8 +6,9 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.downsampleData
 def test_downsampleData():
-    assert os.path.exists(os.path.join(test_output_path, 'sampled.1.fq'))
\ No newline at end of file
+    assert os.path.exists(os.path.join(test_output_path, 'sampled.1.fq'))

workflow/tests/test_fastqc.py

@@ -6,8 +6,10 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.fastqc
 def test_fastqc():
-    assert os.path.exists(os.path.join(test_output_path, 'Q-Y5F6_1M.R1_fastqc.zip'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Q-Y5F6_1M.R1_fastqc.zip'))

workflow/tests/test_getBag.py

@@ -6,8 +6,10 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.getBag
 def test_getBag():
-    assert os.path.exists(os.path.join(test_output_path, 'Replicate_Q-Y5F6.zip'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Replicate_Q-Y5F6.zip'))

workflow/tests/test_getData.py

@@ -6,9 +6,12 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.getData
 def test_getData():
-    assert os.path.exists(os.path.join(test_output_path, 'Replicate_Q-Y5F6/bagit.txt'))
-    assert os.path.exists(os.path.join(test_output_path, 'Replicate_Q-Y5F6/data/assets/Study/Q-Y4GY/Experiment/Q-Y4DP/Replicate/Q-Y5F6/mMARIS_Six2-#3.gene.rpkm.txt'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Replicate_Q-Y5F6/bagit.txt'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Replicate_Q-Y5F6/data/assets/Study/Q-Y4GY/Experiment/Q-Y4DP/Replicate/Q-Y5F6/mMARIS_Six2-#3.gene.rpkm.txt'))

workflow/tests/test_inferMetadata.py

@@ -6,9 +6,10 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.inferMetadata
 def test_inferMetadata():
-    assert os.path.exists(os.path.join(test_output_path, 'Q-Y5F6_1M.se.inferMetadata.log'))
-
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Q-Y5F6_1M.se.inferMetadata.log'))

workflow/tests/test_makeBigWig.py

@@ -6,7 +6,7 @@ import os
 import utils
 
 data_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-	'/../../'
+    '/../../'
 
 
 @pytest.mark.makeBigWig

workflow/tests/test_makeFeatureCounts.py

@@ -6,11 +6,14 @@ import os
 import utils
 
 data_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-	'/../../'
+    '/../../'
 
 
 @pytest.mark.makeFeatureCounts
 def test_makeFeatureCounts():
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.countData'))
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.countTable.csv'))
-	assert os.path.exists(os.path.join(data_output_path, 'Q-Y5F6_1M.se.tpmTable.csv'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.countData'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.countTable.csv'))
+    assert os.path.exists(os.path.join(
+        data_output_path, 'Q-Y5F6_1M.se.tpmTable.csv'))

workflow/tests/test_outputBag.py

@@ -6,7 +6,8 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.outputBag
 def test_outputBag():

workflow/tests/test_parseMetadata.py

@@ -6,13 +6,15 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.parseMetadata
 def test_parseMetadata():
     assert os.path.exists(os.path.join(test_output_path, 'design.csv'))
     assert readLine(os.path.join(test_output_path, 'design.csv'))
 
+
 def readLine(fileName):
     data = False
     file = open(fileName, "r")

workflow/tests/test_trimData.py

@@ -6,14 +6,18 @@ from io import StringIO
 import os
 
 test_output_path = os.path.dirname(os.path.abspath(__file__)) + \
-                '/../../'
+    '/../../'
+
 
 @pytest.mark.trimData
 def test_trimData_se():
-    assert os.path.exists(os.path.join(test_output_path, 'Q-Y5F6_1M.se_trimmed.fq.gz'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Q-Y5F6_1M.se_trimmed.fq.gz'))
 
 
 @pytest.mark.trimData
 def test_trimData_pe():
-    assert os.path.exists(os.path.join(test_output_path, 'Q-Y5F6_1M.pe_R1_val_1.fq.gz'))
-    assert os.path.exists(os.path.join(test_output_path, 'Q-Y5F6_1M.pe_R2_val_2.fq.gz'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Q-Y5F6_1M.pe_R1_val_1.fq.gz'))
+    assert os.path.exists(os.path.join(
+        test_output_path, 'Q-Y5F6_1M.pe_R2_val_2.fq.gz'))