Mercurial > repos > sanbi-uwc > data_manager_rnastar_index_builder
comparison data_manager/rnastar_index_builder.py @ 5:aed097239724 draft
planemo upload for repository https://github.com/pvanheus/data_manager_rnastar_index_builder commit 9d7fb6d7c47e94fb113e0fe26427086935122ff0
| author | sanbi-uwc |
|---|---|
| date | Wed, 10 Feb 2016 07:49:35 -0500 |
| parents | 2883a3b7dc56 |
| children | 56686a746b91 |
comparison
equal
deleted
inserted
replaced
| 4:9d6c9d4bc794 | 5:aed097239724 |
|---|---|
| 1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
| 2 | 2 |
| 3 from __future__ import print_function | 3 from __future__ import print_function |
| 4 import argparse | 4 import argparse |
| 5 from subprocess import check_call, CalledProcessError | 5 from subprocess import check_call, CalledProcessError |
| 6 from json import load, dump | 6 from json import load, dump, dumps |
| 7 from os import environ, mkdir | 7 from os import environ, mkdir, makedirs |
| 8 from os.path import isdir, exists | 8 from os.path import isdir, exists |
| 9 import shlex | 9 import shlex |
| 10 import sys | 10 import sys |
| 11 | 11 |
| 12 def get_id_name( params, dbkey, fasta_description=None): | 12 def get_id_name( params, dbkey, fasta_description=None): |
| 21 if not sequence_name: | 21 if not sequence_name: |
| 22 sequence_name = dbkey | 22 sequence_name = dbkey |
| 23 return sequence_id, sequence_name | 23 return sequence_id, sequence_name |
| 24 | 24 |
| 25 def make_rnastar_index(output_directory, fasta_filename): | 25 def make_rnastar_index(output_directory, fasta_filename): |
| 26 # STAR | 26 #STAR |
| 27 # --runMode genomeGenerate | 27 # --runMode genomeGenerate |
| 28 # --genomeDir tempstargenomedir | 28 # --genomeDir tempstargenomedir |
| 29 # --genomeFastaFiles $input1 | 29 # --genomeFastaFiles $input1 |
| 30 # --runThreadsN \${GALAXY_SLOTS:-1} | 30 # --runThreadsN \${GALAXY_SLOTS:-1} |
| 31 # --genomeChrBinNbits $advanced_options.chr_bin_nbits | 31 # --genomeChrBinNbits $advanced_options.chr_bin_nbits |
| 32 | 32 |
| 33 if exists(output_directory) and not isdir(output_directory): | 33 if exists(output_directory) and not isdir(output_directory): |
| 34 print("Output directory path already exists but is not a directory: {}".format(output_directory), file=sys.stderr) | 34 print("Output directory path already exists but is not a directory: {}".format(output_directory), file=sys.stderr) |
| 35 elif not exists(output_directory): | 35 elif not exists(output_directory): |
| 36 mkdir(output_directory) | 36 mkdir(output_directory) |
| 57 parser.add_argument('--fasta_dbkey') | 57 parser.add_argument('--fasta_dbkey') |
| 58 parser.add_argument('--fasta_description', default=None) | 58 parser.add_argument('--fasta_description', default=None) |
| 59 parser.add_argument('--data_table_name', default='rnastar_indexes') | 59 parser.add_argument('--data_table_name', default='rnastar_indexes') |
| 60 args = parser.parse_args() | 60 args = parser.parse_args() |
| 61 | 61 |
| 62 params = load(open(args.output_filename, 'rb')) | 62 filename = args.output_filename |
| 63 | 63 |
| 64 output_directory = params['output_data'][0]['extra_files_path'] | 64 params = load(open(filename, 'rb')) |
| 65 output_directory = params[ 'output_data' ][0]['extra_files_path'] | |
| 66 makedirs( output_directory ) | |
| 67 data_manager_dict = {} | |
| 65 | 68 |
| 66 make_rnastar_index(output_directory, args.fasta_filename) | 69 make_rnastar_index(output_directory, args.fasta_filename) |
| 67 (sequence_id, sequence_name) = get_id_name(params, args.fasta_dbkey, args.fasta_description) | 70 (sequence_id, sequence_name) = get_id_name(params, args.fasta_dbkey, args.fasta_description) |
| 68 data_table_entry = dict(value=sequence_id, dbkey=args.fasta_dbkey, name=sequence_name, path=output_directory) | 71 data_table_entry = dict(value=sequence_id, dbkey=args.fasta_dbkey, name=sequence_name, path=output_directory) |
| 69 output_datatable_dict = dict('data_tables', dict(args.data_table_name, [data_table_entry])) | |
| 70 | 72 |
| 71 dump(output_datatable_dict(open(args.output_file, 'wb'))) | 73 #dt_tables = {args.data_table_name : [data_table_entry]} |
| 74 output_datatable_dict = dict(data_tables={args.data_table_name : [data_table_entry]}) | |
| 75 open( filename, 'wb' ).write( dumps( output_datatable_dict ) ) |
