-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathfimo_jarray_GATA1_01_5_10000000.sh
113 lines (88 loc) · 3.4 KB
/
fimo_jarray_GATA1_01_5_10000000.sh
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
#!/bin/bash
#MSUB -A p20519
#MSUB -l walltime=168:00:00
#MSUB -l nodes=1:ppn=1
#MSUB -M [email protected]
#MSUB -j oe
#MSUB -o /projects/p20519/jia_output/error_run10142014.txt
#MSUB -m bae
#MSUB -q long
#MSUB -N GATA1_01_jia
#MSUB -V
chunk_size=100
counter=0
search_base=GATA1_01
search=GATA1_01_5_10000000
all_filenames=($(find /projects/p20519/jia_output/FIMO/${search_base}/${search}.* -type f))
output_folder="GATA1_output"
nbatch=${MOAB_JOBARRAYINDEX}
nfiles=${#all_filenames[@]}
max_batch=$(($(($nfiles+$chunk_size-1))/$chunk_size))
#this script will generate one job array (500 jobs)
#how is this different from fimo_script.sh?
#each chunk = batch
# need to utilize ${MOAB_JOBARRAYINDEX}
#need to generate job array script for one batch!
#transform numbers into index
#workflow
# 1. generate index file for all the files
# 2. generate general MOAB.pbs file that utilizes indexes, and has 20 commands
# a. name of the file should include chunk_size
#submit via msub jobname.[1-end index:chunksize] myscript.pbs
generate_pipe () {
#echo "file name is $1"
#echo "base file name is $2"
#echo "counter is $3"
local cmd_filename=$1
local cmd_base_filename=$2
local cmd_counter=$3
pipe_command="mkfifo /projects/p20519/jia_output/FIMO/${output_folder}/${cmd_base_filename}_job${cmd_counter}.txt" # in bash, all variables declared inside the function is shared with the# calling environment
}
generate_command () {
#echo "file name is $1"
#echo "base file name is $2"
#echo "counter is $3"
local cmd_filename=$1
local cmd_base_filename=$2
local cmd_counter=$3
command="fimo --max-stored-scores 500000000 --thresh 0.0001 --max-seq-length 250000000 --text /projects/p20519/jia_output/TRANSFAC2FIMO_3242014.txt $cmd_filename >> /projects/p20519/jia_output/FIMO/${output_folder}/${cmd_base_filename}_job${cmd_counter}.txt &" # in bash, all variables declared inside the function is shared with the calling environment
}
generate_compress_command () {
#echo "file name is $1"
#echo "base file name is $2"
#echo "counter is $3"
local cmd_filename=$1
local cmd_base_filename=$2
local cmd_counter=$3
compress_command="cat /projects/p20519/jia_output/FIMO/${output_folder}/${cmd_base_filename}_job${cmd_counter}.txt | python /home/jjw036/SequenceGenerator/scripts/FimoEvaluator.py"
}
echo "Processing ${nfiles} files in ${max_batch} batches"
counter=$(($nbatch*$chunk_size))
end_index=0
file_batch=()
command_list=""
end_index=$(($chunk_size+$counter))
if [ "${counter}" -gt "${nfiles}" ]
then
counter=0
fi
if [ "${chunk_size}" -gt "${nfiles}" ]
then
chunk_size=${nfiles}
fi
if [ "${end_index}" -gt "${nfiles}" ]
then
echo "last batch"
end_index=$(($nfiles-1))
fi
file_batch=("${all_filenames[@]:$counter:$chunk_size}")
echo "Processing batch $nbatch"
for filename in ${file_batch[*]};
do
base_filename=$(basename "$filename")
extension="${base_filename##*.}"
base_filename="${base_filename%.*}"
mkfifo /projects/p20519/jia_output/FIMO/${output_folder}/${base_filename}_job${extension}.txt
fimo --max-stored-scores 500000000 --thresh 0.0001 --max-seq-length 250000000 --text /projects/p20519/jia_output/TRANSFAC2FIMO_3242014.txt $filename >> /projects/p20519/jia_output/FIMO/${output_folder}/${base_filename}_job${extension}.txt &
cat /projects/p20519/jia_output/FIMO/${output_folder}/${base_filename}_job${extension}.txt | python /home/jjw036/SequenceGenerator/scripts/FimoEvaluator.py
done