aboutsummaryrefslogtreecommitdiffstats
path: root/submitter/make_dag.py
blob: 53878a2fec370d35dd81d9fa358f0a7cf87d7946 (plain)
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
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
#! /usr/bin/env python

import os
import numpy as np

a_fr = (1, 2, 0)
b_fr = (1, 0, 0)
c_fr = (0, 1, 0)
d_fr = (0, 0, 1)
e_fr = (1, 1, 1)
f_fr = (2, 1, 0)
g_fr = (1, 1, 0)

full_scan_mfr = [
    # (1, 1, 1), (1, 1, 0)
]

fix_sfr_mfr = [
    (1, 1, 1, 1, 2, 0),
    # (1, 1, 0, 1, 2, 0),
    # (1, 2, 0, 1, 2, 0),
    # (1, 1, 1, 1, 0, 0),
    # (1, 1, 0, 1, 0, 0),
    # (1, 0, 0, 1, 0, 0),
    # (1, 1, 1, 0, 1, 0),
    # (1, 1, 0, 0, 1, 0),
    # (0, 1, 0, 0, 1, 0),
    # (1, 2, 0, 0, 1, 0),
    # (1, 1, 1, 0, 0, 1),
]

# MCMC
run_mcmc = 'False'
burnin   = 500
nsteps   = 2000
nwalkers = 60
seed     = 24
threads  = 1
mcmc_seed_type = 'uniform'

# FR
dimension         = [6]
energy            = [1e6]
likelihood        = 'golemfit'
no_bsm            = 'False'
sigma_ratio       = ['0.01']
scale             = "1E-20 1E-30"
scale_region      = "1E10"
energy_dependance = 'spectral'
spectral_index    = -2
binning           = [1e4, 1e7, 5]
fix_mixing        = 'False'
fix_mixing_almost = 'False'

# Likelihood
likelihood = 'golemfit'

# Nuisance
convNorm        = 1.
promptNorm      = 0.
muonNorm        = 1.
astroNorm       = 6.9
astroDeltaGamma = 2.5

# GolemFit
ast  = 'p2_0'
data = 'real'

# Bayes Factor
run_bayes_factor  = 'False'
run_angles_limit  = 'True'
bayes_bins        = 10
bayes_live_points = 200
bayes_tolerance   = 0.01
bayes_eval_bin    = True # set to 'all' to run normally

# Plot
plot_angles   = 'False'
plot_elements = 'False'
plot_bayes    = 'False'

outfile = 'dagman_FR_angles_limit.submit'
golemfitsourcepath = os.environ['GOLEMSOURCEPATH'] + '/GolemFit'
condor_script = golemfitsourcepath + '/scripts/flavour_ratio/submitter/submit.sub'

if bayes_eval_bin != 'all': b_runs = bayes_bins
else: b_runs = 1

with open(outfile, 'w') as f:
    job_number = 1
    for dim in dimension:
        print 'dimension', dim
        for en in energy:
            print 'energy {0:.0E}'.format(en)

            if energy_dependance == 'mono':
                outchain_head = '/data/user/smandalia/flavour_ratio/data/{0}/DIM{1}/{2:.0E}'.format(likelihood, dim, en)
            elif energy_dependance == 'spectral':
                outchain_head = '/data/user/smandalia/flavour_ratio/data/{0}/DIM{1}/SI_{2}'.format(likelihood, dim, spectral_index)

            bayes_output = 'None'
            for sig in sigma_ratio:
                print 'sigma', sig
                for frs in fix_sfr_mfr:
                    print frs
                    outchains = outchain_head + '/fix_ifr/{0}/'.format(str(sig).replace('.', '_'))
                    if run_bayes_factor == 'True':
                        bayes_output = outchains + '/bayes_factor/'
                    if run_angles_limit == 'True':
                        angles_lim_output = outchains + '/angles_limit/'
                    outchains += 'mcmc_chain'
                    for r in range(b_runs):
                        print 'run', r
                        f.write('JOB\tjob{0}\t{1}\n'.format(job_number, condor_script))
                        f.write('VARS\tjob{0}\tmr0="{1}"\n'.format(job_number, frs[0]))
                        f.write('VARS\tjob{0}\tmr1="{1}"\n'.format(job_number, frs[1]))
                        f.write('VARS\tjob{0}\tmr2="{1}"\n'.format(job_number, frs[2]))
                        f.write('VARS\tjob{0}\tsigma_ratio="{1}"\n'.format(job_number, sig))
                        f.write('VARS\tjob{0}\tfix_source_ratio="{1}"\n'.format(job_number, 'True'))
                        f.write('VARS\tjob{0}\tsr0="{1}"\n'.format(job_number, frs[3]))
                        f.write('VARS\tjob{0}\tsr1="{1}"\n'.format(job_number, frs[4]))
                        f.write('VARS\tjob{0}\tsr2="{1}"\n'.format(job_number, frs[5]))
                        f.write('VARS\tjob{0}\tfix_scale="{1}"\n'.format(job_number, 'False'))
                        f.write('VARS\tjob{0}\tscale="{1}"\n'.format(job_number, 0))
                        f.write('VARS\tjob{0}\tscale_region="{1}"\n'.format(job_number, scale_region))
                        f.write('VARS\tjob{0}\tdimension="{1}"\n'.format(job_number, dim))
                        f.write('VARS\tjob{0}\tenergy="{1}"\n'.format(job_number, en))
                        f.write('VARS\tjob{0}\tlikelihood="{1}"\n'.format(job_number, likelihood))
                        f.write('VARS\tjob{0}\tburnin="{1}"\n'.format(job_number, burnin))
                        f.write('VARS\tjob{0}\tnwalkers="{1}"\n'.format(job_number, nwalkers))
                        f.write('VARS\tjob{0}\tnsteps="{1}"\n'.format(job_number, nsteps))
                        f.write('VARS\tjob{0}\toutfile="{1}"\n'.format(job_number, outchains))
                        f.write('VARS\tjob{0}\tfix_mixing="{1}"\n'.format(job_number, fix_mixing))
                        f.write('VARS\tjob{0}\tno_bsm="{1}"\n'.format(job_number, no_bsm))
                        f.write('VARS\tjob{0}\trun_mcmc="{1}"\n'.format(job_number, run_mcmc))
                        f.write('VARS\tjob{0}\tastroDeltaGamma="{1}"\n'.format(job_number, astroDeltaGamma))
                        f.write('VARS\tjob{0}\tastroNorm="{1}"\n'.format(job_number, astroNorm))
                        f.write('VARS\tjob{0}\tconvNorm="{1}"\n'.format(job_number, convNorm))
                        f.write('VARS\tjob{0}\tmuonNorm="{1}"\n'.format(job_number, muonNorm))
                        f.write('VARS\tjob{0}\tpromptNorm="{1}"\n'.format(job_number, promptNorm))
                        f.write('VARS\tjob{0}\tdata="{1}"\n'.format(job_number, data))
                        f.write('VARS\tjob{0}\tast="{1}"\n'.format(job_number, ast))
                        f.write('VARS\tjob{0}\tplot_angles="{1}"\n'.format(job_number, plot_angles))
                        f.write('VARS\tjob{0}\tplot_elements="{1}"\n'.format(job_number, plot_elements))
                        f.write('VARS\tjob{0}\tseed="{1}"\n'.format(job_number, seed))
                        f.write('VARS\tjob{0}\tthreads="{1}"\n'.format(job_number, threads))
                        f.write('VARS\tjob{0}\tlikelihood="{1}"\n'.format(job_number, likelihood))
                        f.write('VARS\tjob{0}\tmcmc_seed_type="{1}"\n'.format(job_number, mcmc_seed_type))
                        f.write('VARS\tjob{0}\tenergy_dependance="{1}"\n'.format(job_number, energy_dependance))
                        f.write('VARS\tjob{0}\tspectral_index="{1}"\n'.format(job_number, spectral_index))
                        f.write('VARS\tjob{0}\tbinning_0="{1}"\n'.format(job_number, binning[0]))
                        f.write('VARS\tjob{0}\tbinning_1="{1}"\n'.format(job_number, binning[1]))
                        f.write('VARS\tjob{0}\tbinning_2="{1}"\n'.format(job_number, binning[2]))
                        f.write('VARS\tjob{0}\tfix_mixing_almost="{1}"\n'.format(job_number, fix_mixing_almost))
                        f.write('VARS\tjob{0}\trun_bayes_factor="{1}"\n'.format(job_number, run_bayes_factor))
                        f.write('VARS\tjob{0}\tbayes_bins="{1}"\n'.format(job_number, bayes_bins))
                        f.write('VARS\tjob{0}\tbayes_output="{1}"\n'.format(job_number, bayes_output))
                        f.write('VARS\tjob{0}\tbayes_live_points="{1}"\n'.format(job_number, bayes_live_points))
                        f.write('VARS\tjob{0}\tbayes_tolerance="{1}"\n'.format(job_number, bayes_tolerance))
                        f.write('VARS\tjob{0}\tplot_bayes="{1}"\n'.format(job_number, plot_bayes))
                        f.write('VARS\tjob{0}\tbayes_eval_bin="{1}"\n'.format(job_number, r))
                        f.write('VARS\tjob{0}\trun_angles_limit="{1}"\n'.format(job_number, run_angles_limit))
                        f.write('VARS\tjob{0}\tangles_lim_output="{1}"\n'.format(job_number, angles_lim_output))
                        job_number += 1

                for frs in full_scan_mfr:
                    print frs
                    outchains = outchain_head + '/full_scan/{0}'.format(str(sig).replace('.', '_'))
                    if run_bayes_factor == 'True':
                        bayes_output = outchains + '/bayes_factor/'
                    if run_angles_limit == 'True':
                        angles_lim_output = outchains + '/angles_limit/'
                    outchains += 'mcmc_chain'
                    for r in range(b_runs):
                        print 'run', r
                        f.write('JOB\tjob{0}\t{1}\n'.format(job_number, condor_script))
                        f.write('VARS\tjob{0}\tmr0="{1}"\n'.format(job_number, frs[0]))
                        f.write('VARS\tjob{0}\tmr1="{1}"\n'.format(job_number, frs[1]))
                        f.write('VARS\tjob{0}\tmr2="{1}"\n'.format(job_number, frs[2]))
                        f.write('VARS\tjob{0}\tsigma_ratio="{1}"\n'.format(job_number, sig))
                        f.write('VARS\tjob{0}\tfix_source_ratio="{1}"\n'.format(job_number, 'False'))
                        f.write('VARS\tjob{0}\tsr0="{1}"\n'.format(job_number, 0))
                        f.write('VARS\tjob{0}\tsr1="{1}"\n'.format(job_number, 0))
                        f.write('VARS\tjob{0}\tsr2="{1}"\n'.format(job_number, 0))
                        f.write('VARS\tjob{0}\tfix_scale="{1}"\n'.format(job_number, 'False'))
                        f.write('VARS\tjob{0}\tscale="{1}"\n'.format(job_number, 0))
                        f.write('VARS\tjob{0}\tscale_region="{1}"\n'.format(job_number, scale_region))
                        f.write('VARS\tjob{0}\tdimension="{1}"\n'.format(job_number, dim))
                        f.write('VARS\tjob{0}\tenergy="{1}"\n'.format(job_number, en))
                        f.write('VARS\tjob{0}\tlikelihood="{1}"\n'.format(job_number, likelihood))
                        f.write('VARS\tjob{0}\tburnin="{1}"\n'.format(job_number, burnin))
                        f.write('VARS\tjob{0}\tnwalkers="{1}"\n'.format(job_number, nwalkers))
                        f.write('VARS\tjob{0}\tnsteps="{1}"\n'.format(job_number, nsteps))
                        f.write('VARS\tjob{0}\toutfile="{1}"\n'.format(job_number, outchains))
                        f.write('VARS\tjob{0}\tfix_mixing="{1}"\n'.format(job_number, fix_mixing))
                        f.write('VARS\tjob{0}\tno_bsm="{1}"\n'.format(job_number, no_bsm))
                        f.write('VARS\tjob{0}\trun_mcmc="{1}"\n'.format(job_number, run_mcmc))
                        f.write('VARS\tjob{0}\tastroDeltaGamma="{1}"\n'.format(job_number, astroDeltaGamma))
                        f.write('VARS\tjob{0}\tastroNorm="{1}"\n'.format(job_number, astroNorm))
                        f.write('VARS\tjob{0}\tconvNorm="{1}"\n'.format(job_number, convNorm))
                        f.write('VARS\tjob{0}\tmuonNorm="{1}"\n'.format(job_number, muonNorm))
                        f.write('VARS\tjob{0}\tpromptNorm="{1}"\n'.format(job_number, promptNorm))
                        f.write('VARS\tjob{0}\tdata="{1}"\n'.format(job_number, data))
                        f.write('VARS\tjob{0}\tast="{1}"\n'.format(job_number, ast))
                        f.write('VARS\tjob{0}\tplot_angles="{1}"\n'.format(job_number, plot_angles))
                        f.write('VARS\tjob{0}\tplot_elements="{1}"\n'.format(job_number, plot_elements))
                        f.write('VARS\tjob{0}\tseed="{1}"\n'.format(job_number, seed))
                        f.write('VARS\tjob{0}\tthreads="{1}"\n'.format(job_number, threads))
                        f.write('VARS\tjob{0}\tlikelihood="{1}"\n'.format(job_number, likelihood))
                        f.write('VARS\tjob{0}\tmcmc_seed_type="{1}"\n'.format(job_number, mcmc_seed_type))
                        f.write('VARS\tjob{0}\tenergy_dependance="{1}"\n'.format(job_number, energy_dependance))
                        f.write('VARS\tjob{0}\tspectral_index="{1}"\n'.format(job_number, spectral_index))
                        f.write('VARS\tjob{0}\tbinning_0="{1}"\n'.format(job_number, binning[0]))
                        f.write('VARS\tjob{0}\tbinning_1="{1}"\n'.format(job_number, binning[1]))
                        f.write('VARS\tjob{0}\tbinning_2="{1}"\n'.format(job_number, binning[2]))
                        f.write('VARS\tjob{0}\tfix_mixing_almost="{1}"\n'.format(job_number, fix_mixing_almost))
                        f.write('VARS\tjob{0}\trun_bayes_factor="{1}"\n'.format(job_number, run_bayes_factor))
                        f.write('VARS\tjob{0}\tbayes_bins="{1}"\n'.format(job_number, bayes_bins))
                        f.write('VARS\tjob{0}\tbayes_output="{1}"\n'.format(job_number, bayes_output))
                        f.write('VARS\tjob{0}\tbayes_live_points="{1}"\n'.format(job_number, bayes_live_points))
                        f.write('VARS\tjob{0}\tbayes_tolerance="{1}"\n'.format(job_number, bayes_tolerance))
                        f.write('VARS\tjob{0}\tplot_bayes="{1}"\n'.format(job_number, plot_bayes))
                        f.write('VARS\tjob{0}\tbayes_eval_bin="{1}"\n'.format(job_number, r))
                        f.write('VARS\tjob{0}\trun_angles_limit="{1}"\n'.format(job_number, run_angles_limit))
                        f.write('VARS\tjob{0}\tangles_lim_output="{1}"\n'.format(job_number, angles_lim_output))
                        job_number += 1