Mercurial > repos > pjbriggs > amplicon_analysis_pipeline
comparison amplicon_analysis_pipeline.py @ 3:3ab198df8f3f draft
planemo upload for repository https://github.com/pjbriggs/Amplicon_analysis-galaxy commit 15390f18b91d838880d952eb2714f689bbd8a042
| author | pjbriggs |
|---|---|
| date | Thu, 18 Oct 2018 09:18:04 -0400 |
| parents | 1c1902e12caf |
| children | 86a12d75ebe4 |
comparison
equal
deleted
inserted
replaced
| 2:43d6f81bc667 | 3:3ab198df8f3f |
|---|---|
| 58 for line in message.split('\n'): | 58 for line in message.split('\n'): |
| 59 sys.stderr.write("* %s%s *\n" % (line,' '*(width-len(line)-4))) | 59 sys.stderr.write("* %s%s *\n" % (line,' '*(width-len(line)-4))) |
| 60 sys.stderr.write("%s\n\n" % ('*'*width)) | 60 sys.stderr.write("%s\n\n" % ('*'*width)) |
| 61 | 61 |
| 62 def clean_up_name(sample): | 62 def clean_up_name(sample): |
| 63 # Remove trailing "_L[0-9]+_001" from Fastq | 63 # Remove extensions and trailing "_L[0-9]+_001" from |
| 64 # pair names | 64 # Fastq pair names |
| 65 split_name = sample.split('_') | 65 sample_name = '.'.join(sample.split('.')[:1]) |
| 66 split_name = sample_name.split('_') | |
| 66 if split_name[-1] == "001": | 67 if split_name[-1] == "001": |
| 67 split_name = split_name[:-1] | 68 split_name = split_name[:-1] |
| 68 if split_name[-1].startswith('L'): | 69 if split_name[-1].startswith('L'): |
| 69 try: | 70 try: |
| 70 int(split_name[-1][1:]) | 71 int(split_name[-1][1:]) |
| 137 os.symlink(categories_file,"Categories.txt") | 138 os.symlink(categories_file,"Categories.txt") |
| 138 print "-- made symlink to Categories.txt" | 139 print "-- made symlink to Categories.txt" |
| 139 | 140 |
| 140 # Link to FASTQs and construct Final_name.txt file | 141 # Link to FASTQs and construct Final_name.txt file |
| 141 sample_names = [] | 142 sample_names = [] |
| 143 print "-- making Final_name.txt" | |
| 142 with open("Final_name.txt",'w') as final_name: | 144 with open("Final_name.txt",'w') as final_name: |
| 143 fastqs = iter(args.fastq_pairs) | 145 fastqs = iter(args.fastq_pairs) |
| 144 for sample_name,fqr1,fqr2 in zip(fastqs,fastqs,fastqs): | 146 for sample_name,fqr1,fqr2 in zip(fastqs,fastqs,fastqs): |
| 145 sample_name = clean_up_name(sample_name) | 147 sample_name = clean_up_name(sample_name) |
| 148 print " %s" % sample_name | |
| 146 r1 = "%s_R1_.fastq" % sample_name | 149 r1 = "%s_R1_.fastq" % sample_name |
| 147 r2 = "%s_R2_.fastq" % sample_name | 150 r2 = "%s_R2_.fastq" % sample_name |
| 148 os.symlink(fqr1,r1) | 151 os.symlink(fqr1,r1) |
| 149 os.symlink(fqr2,r2) | 152 os.symlink(fqr2,r2) |
| 150 final_name.write("%s\n" % '\t'.join((r1,sample_name))) | 153 final_name.write("%s\n" % '\t'.join((r1,sample_name))) |