LALInference 4.1.9.1-eeff03c
Variables
lalinference_burst_pp_pipe Namespace Reference

Variables

string usage
 
 parser = OptionParser(usage)
 
 default
 
 action
 
 type
 
 help
 
 metavar
 
 None
 
 opts
 
 args
 
 inifile = args[0]
 
 prior_cp = ConfigParser()
 
 optionxform
 
 main_cp = ConfigParser()
 
 rundir = os.path.abspath(opts.run_path)
 
 daglogdir = os.path.abspath(opts.daglog_path)
 
 webdir = main_cp.get('ppanalysis','webdir')
 
 priordir = os.path.join(rundir,'prior')
 
 maindir = os.path.join(rundir,'main')
 
 priorwebdir = os.path.join(webdir,'prior')
 
 mainwebdir = os.path.join(webdir,'injections')
 
 outerlogdir = os.path.join(daglogdir,'log')
 
 outerdaglog = os.path.join(daglogdir,'lalinference_injection_test_'+str(uuid.uuid1())+'.log')
 
 outerdag = pipeline.CondorDAG(outerdaglog)
 
int trig_time = 1085855789
 
 fake_event = pipe_utils.Event(trig_time=trig_time)
 
 tfpath = os.path.join(rundir,'time.txt')
 
 tfile = open(tfpath,'w')
 
 file
 
 priordag = pipe_utils.LALInferencePipelineDAG(prior_cp)
 
 priordagjob = pipeline.CondorDAGManJob(priordag.get_dag_file(),dir=priordir)
 
 priordagnode = pipeline.CondorDAGManNode(priordagjob)
 
 pagenode = filter(lambda n:isinstance(n,pipe_utils.ResultsPageNode), priordag.get_nodes())[0]
 
 priorfile = pagenode.get_pos_file()
 
 convertsub = os.path.join(rundir,'samples2injections.sub')
 
 converterr = os.path.join(outerlogdir,'samples2injection-$(cluster)-$(process)-$(node).err')
 
 convertout = os.path.join(outerlogdir,'samples2injection-$(cluster)-$(process)-$(node).out')
 
 injfile = os.path.abspath(opts.injections)
 
 approx = prior_cp.get('engine','approx')
 
 prior2injexe = prior_cp.get('condor','pos_to_sim_burst')
 
 prior2injjob = pipeline.CondorDAGJob('vanilla',prior2injexe)
 
 prior2injnode = pipeline.CondorDAGNode(prior2injjob)
 
 maindag = pipe_utils.LALInferencePipelineDAG(main_cp)
 
 maindagjob = pipeline.CondorDAGManJob(maindag.get_dag_file(),dir=maindir)
 
 maindagnode = pipeline.CondorDAGManNode(maindagjob)
 
 ev = pipe_utils.Event(trig_time=trig_time,event_id=i)
 
 e = maindag.add_full_analysis(ev)
 
 resultspagenodes = filter(lambda n: isinstance(n, pipe_utils.ResultsPageNode), maindag.get_nodes())
 
list posteriorfiles = [n.get_pos_file() for n in resultspagenodes]
 
 ppsub = os.path.join(rundir,'ppanalysis.sub')
 
 pperr = os.path.join(outerlogdir,'ppanalysis-$(cluster)-$(process)-$(node).err')
 
 ppout = os.path.join(outerlogdir,'ppanalysis-$(cluster)-$(process)-$(node).out')
 
 ppexe = prior_cp.get('condor','ppanalysis')
 
 ppjob = pipeline.CondorDAGJob('vanilla',ppexe)
 
 ppnode = pipeline.CondorDAGNode(ppjob)
 
 outdir = main_cp.get('ppanalysis','webdir')
 

Variable Documentation

◆ usage

string lalinference_burst_pp_pipe.usage ( void  )
Initial value:
1= """ %prog [options] config.ini
2Setup a DAG to run an end-to-end lalinference test:
3 1) Generate samples from prior
4 2) Analyse a set of injections drawn from the prior
5 3) Run P vs P test on results
6"""

Definition at line 19 of file lalinference_burst_pp_pipe.py.

◆ parser

lalinference_burst_pp_pipe.parser = OptionParser(usage)

Definition at line 26 of file lalinference_burst_pp_pipe.py.

◆ default

lalinference_burst_pp_pipe.default

Definition at line 27 of file lalinference_burst_pp_pipe.py.

◆ action

lalinference_burst_pp_pipe.action

Definition at line 27 of file lalinference_burst_pp_pipe.py.

◆ type

lalinference_burst_pp_pipe.type

Definition at line 27 of file lalinference_burst_pp_pipe.py.

◆ help

lalinference_burst_pp_pipe.help

Definition at line 27 of file lalinference_burst_pp_pipe.py.

◆ metavar

lalinference_burst_pp_pipe.metavar

Definition at line 27 of file lalinference_burst_pp_pipe.py.

◆ None

lalinference_burst_pp_pipe.None

Definition at line 28 of file lalinference_burst_pp_pipe.py.

◆ opts

lalinference_burst_pp_pipe.opts

Definition at line 33 of file lalinference_burst_pp_pipe.py.

◆ args

lalinference_burst_pp_pipe.args

Definition at line 33 of file lalinference_burst_pp_pipe.py.

◆ inifile

lalinference_burst_pp_pipe.inifile = args[0]

Definition at line 39 of file lalinference_burst_pp_pipe.py.

◆ prior_cp

lalinference_burst_pp_pipe.prior_cp = ConfigParser()

Definition at line 43 of file lalinference_burst_pp_pipe.py.

◆ optionxform

lalinference_burst_pp_pipe.optionxform

Definition at line 44 of file lalinference_burst_pp_pipe.py.

◆ main_cp

lalinference_burst_pp_pipe.main_cp = ConfigParser()

Definition at line 50 of file lalinference_burst_pp_pipe.py.

◆ rundir

lalinference_burst_pp_pipe.rundir = os.path.abspath(opts.run_path)

Definition at line 58 of file lalinference_burst_pp_pipe.py.

◆ daglogdir

lalinference_burst_pp_pipe.daglogdir = os.path.abspath(opts.daglog_path)

Definition at line 63 of file lalinference_burst_pp_pipe.py.

◆ webdir

lalinference_burst_pp_pipe.webdir = main_cp.get('ppanalysis','webdir')

Definition at line 69 of file lalinference_burst_pp_pipe.py.

◆ priordir

lalinference_burst_pp_pipe.priordir = os.path.join(rundir,'prior')

Definition at line 70 of file lalinference_burst_pp_pipe.py.

◆ maindir

lalinference_burst_pp_pipe.maindir = os.path.join(rundir,'main')

Definition at line 71 of file lalinference_burst_pp_pipe.py.

◆ priorwebdir

lalinference_burst_pp_pipe.priorwebdir = os.path.join(webdir,'prior')

Definition at line 72 of file lalinference_burst_pp_pipe.py.

◆ mainwebdir

lalinference_burst_pp_pipe.mainwebdir = os.path.join(webdir,'injections')

Definition at line 73 of file lalinference_burst_pp_pipe.py.

◆ outerlogdir

lalinference_burst_pp_pipe.outerlogdir = os.path.join(daglogdir,'log')

Definition at line 79 of file lalinference_burst_pp_pipe.py.

◆ outerdaglog

lalinference_burst_pp_pipe.outerdaglog = os.path.join(daglogdir,'lalinference_injection_test_'+str(uuid.uuid1())+'.log')

Definition at line 106 of file lalinference_burst_pp_pipe.py.

◆ outerdag

lalinference_burst_pp_pipe.outerdag = pipeline.CondorDAG(outerdaglog)

Definition at line 107 of file lalinference_burst_pp_pipe.py.

◆ trig_time

int lalinference_burst_pp_pipe.trig_time = 1085855789

Definition at line 111 of file lalinference_burst_pp_pipe.py.

◆ fake_event

lalinference_burst_pp_pipe.fake_event = pipe_utils.Event(trig_time=trig_time)

Definition at line 112 of file lalinference_burst_pp_pipe.py.

◆ tfpath

lalinference_burst_pp_pipe.tfpath = os.path.join(rundir,'time.txt')

Definition at line 113 of file lalinference_burst_pp_pipe.py.

◆ tfile

lalinference_burst_pp_pipe.tfile = open(tfpath,'w')

Definition at line 114 of file lalinference_burst_pp_pipe.py.

◆ file

lalinference_burst_pp_pipe.file

Definition at line 115 of file lalinference_burst_pp_pipe.py.

◆ priordag

lalinference_burst_pp_pipe.priordag = pipe_utils.LALInferencePipelineDAG(prior_cp)

Definition at line 119 of file lalinference_burst_pp_pipe.py.

◆ priordagjob

lalinference_burst_pp_pipe.priordagjob = pipeline.CondorDAGManJob(priordag.get_dag_file(),dir=priordir)

Definition at line 121 of file lalinference_burst_pp_pipe.py.

◆ priordagnode

lalinference_burst_pp_pipe.priordagnode = pipeline.CondorDAGManNode(priordagjob)

Definition at line 122 of file lalinference_burst_pp_pipe.py.

◆ pagenode

lalinference_burst_pp_pipe.pagenode = filter(lambda n:isinstance(n,pipe_utils.ResultsPageNode), priordag.get_nodes())[0]

Definition at line 124 of file lalinference_burst_pp_pipe.py.

◆ priorfile

lalinference_burst_pp_pipe.priorfile = pagenode.get_pos_file()

Definition at line 125 of file lalinference_burst_pp_pipe.py.

◆ convertsub

lalinference_burst_pp_pipe.convertsub = os.path.join(rundir,'samples2injections.sub')

Definition at line 128 of file lalinference_burst_pp_pipe.py.

◆ converterr

lalinference_burst_pp_pipe.converterr = os.path.join(outerlogdir,'samples2injection-$(cluster)-$(process)-$(node).err')

Definition at line 129 of file lalinference_burst_pp_pipe.py.

◆ convertout

lalinference_burst_pp_pipe.convertout = os.path.join(outerlogdir,'samples2injection-$(cluster)-$(process)-$(node).out')

Definition at line 130 of file lalinference_burst_pp_pipe.py.

◆ injfile

lalinference_burst_pp_pipe.injfile = os.path.abspath(opts.injections)

Definition at line 133 of file lalinference_burst_pp_pipe.py.

◆ approx

lalinference_burst_pp_pipe.approx = prior_cp.get('engine','approx')

Definition at line 136 of file lalinference_burst_pp_pipe.py.

◆ prior2injexe

lalinference_burst_pp_pipe.prior2injexe = prior_cp.get('condor','pos_to_sim_burst')

Definition at line 137 of file lalinference_burst_pp_pipe.py.

◆ prior2injjob

lalinference_burst_pp_pipe.prior2injjob = pipeline.CondorDAGJob('vanilla',prior2injexe)

Definition at line 138 of file lalinference_burst_pp_pipe.py.

◆ prior2injnode

lalinference_burst_pp_pipe.prior2injnode = pipeline.CondorDAGNode(prior2injjob)

Definition at line 145 of file lalinference_burst_pp_pipe.py.

◆ maindag

lalinference_burst_pp_pipe.maindag = pipe_utils.LALInferencePipelineDAG(main_cp)

Definition at line 156 of file lalinference_burst_pp_pipe.py.

◆ maindagjob

lalinference_burst_pp_pipe.maindagjob = pipeline.CondorDAGManJob(maindag.get_dag_file(),dir=maindir)

Definition at line 158 of file lalinference_burst_pp_pipe.py.

◆ maindagnode

lalinference_burst_pp_pipe.maindagnode = pipeline.CondorDAGManNode(maindagjob)

Definition at line 159 of file lalinference_burst_pp_pipe.py.

◆ ev

lalinference_burst_pp_pipe.ev = pipe_utils.Event(trig_time=trig_time,event_id=i)

Definition at line 162 of file lalinference_burst_pp_pipe.py.

◆ e

lalinference_burst_pp_pipe.e = maindag.add_full_analysis(ev)

Definition at line 163 of file lalinference_burst_pp_pipe.py.

◆ resultspagenodes

lalinference_burst_pp_pipe.resultspagenodes = filter(lambda n: isinstance(n, pipe_utils.ResultsPageNode), maindag.get_nodes())

Definition at line 173 of file lalinference_burst_pp_pipe.py.

◆ posteriorfiles

list lalinference_burst_pp_pipe.posteriorfiles = [n.get_pos_file() for n in resultspagenodes]

Definition at line 174 of file lalinference_burst_pp_pipe.py.

◆ ppsub

lalinference_burst_pp_pipe.ppsub = os.path.join(rundir,'ppanalysis.sub')

Definition at line 177 of file lalinference_burst_pp_pipe.py.

◆ pperr

lalinference_burst_pp_pipe.pperr = os.path.join(outerlogdir,'ppanalysis-$(cluster)-$(process)-$(node).err')

Definition at line 178 of file lalinference_burst_pp_pipe.py.

◆ ppout

lalinference_burst_pp_pipe.ppout = os.path.join(outerlogdir,'ppanalysis-$(cluster)-$(process)-$(node).out')

Definition at line 179 of file lalinference_burst_pp_pipe.py.

◆ ppexe

lalinference_burst_pp_pipe.ppexe = prior_cp.get('condor','ppanalysis')

Definition at line 180 of file lalinference_burst_pp_pipe.py.

◆ ppjob

lalinference_burst_pp_pipe.ppjob = pipeline.CondorDAGJob('vanilla',ppexe)

Definition at line 181 of file lalinference_burst_pp_pipe.py.

◆ ppnode

lalinference_burst_pp_pipe.ppnode = pipeline.CondorDAGNode(ppjob)

Definition at line 189 of file lalinference_burst_pp_pipe.py.

◆ outdir

lalinference_burst_pp_pipe.outdir = main_cp.get('ppanalysis','webdir')

Definition at line 192 of file lalinference_burst_pp_pipe.py.