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_inspiral')

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

	prior2injnode = pipeline.CondorDAGNode(prior2injjob)

	amporder = prior_cp.get('engine','amporder')

	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_pp_pipe.usage ( void )

Initial value:

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

Definition at line 18 of file lalinference_pp_pipe.py.

◆ parser

lalinference_pp_pipe.parser = OptionParser(usage)

Definition at line 25 of file lalinference_pp_pipe.py.

◆ default

lalinference_pp_pipe.default

Definition at line 26 of file lalinference_pp_pipe.py.

◆ action

lalinference_pp_pipe.action

Definition at line 26 of file lalinference_pp_pipe.py.

◆ type

lalinference_pp_pipe.type

Definition at line 26 of file lalinference_pp_pipe.py.

◆ help

lalinference_pp_pipe.help

Definition at line 26 of file lalinference_pp_pipe.py.

◆ metavar

lalinference_pp_pipe.metavar

Definition at line 26 of file lalinference_pp_pipe.py.

◆ None

lalinference_pp_pipe.None

Definition at line 27 of file lalinference_pp_pipe.py.

◆ opts

lalinference_pp_pipe.opts

Definition at line 32 of file lalinference_pp_pipe.py.

◆ args

lalinference_pp_pipe.args

Definition at line 32 of file lalinference_pp_pipe.py.

◆ inifile

lalinference_pp_pipe.inifile = args[0]

Definition at line 38 of file lalinference_pp_pipe.py.

◆ prior_cp

lalinference_pp_pipe.prior_cp = ConfigParser()

Definition at line 42 of file lalinference_pp_pipe.py.

◆ optionxform

lalinference_pp_pipe.optionxform

Definition at line 43 of file lalinference_pp_pipe.py.

◆ main_cp

lalinference_pp_pipe.main_cp = ConfigParser()

Definition at line 46 of file lalinference_pp_pipe.py.

◆ rundir

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

Definition at line 55 of file lalinference_pp_pipe.py.

◆ daglogdir

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

Definition at line 60 of file lalinference_pp_pipe.py.

◆ webdir

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

Definition at line 66 of file lalinference_pp_pipe.py.

◆ priordir

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

Definition at line 67 of file lalinference_pp_pipe.py.

◆ maindir

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

Definition at line 68 of file lalinference_pp_pipe.py.

◆ priorwebdir

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

Definition at line 69 of file lalinference_pp_pipe.py.

◆ mainwebdir

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

Definition at line 70 of file lalinference_pp_pipe.py.

◆ outerlogdir

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

Definition at line 76 of file lalinference_pp_pipe.py.

◆ outerdaglog

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

Definition at line 104 of file lalinference_pp_pipe.py.

◆ outerdag

lalinference_pp_pipe.outerdag = pipeline.CondorDAG(outerdaglog)

Definition at line 105 of file lalinference_pp_pipe.py.

◆ trig_time

int lalinference_pp_pipe.trig_time = 1085855789

Definition at line 109 of file lalinference_pp_pipe.py.

◆ fake_event

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

Definition at line 110 of file lalinference_pp_pipe.py.

◆ tfpath

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

Definition at line 111 of file lalinference_pp_pipe.py.

◆ tfile

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

Definition at line 112 of file lalinference_pp_pipe.py.

◆ file

lalinference_pp_pipe.file

Definition at line 113 of file lalinference_pp_pipe.py.

◆ priordag

lalinference_pp_pipe.priordag = pipe_utils.LALInferencePipelineDAG(prior_cp)

Definition at line 117 of file lalinference_pp_pipe.py.

◆ priordagjob

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

Definition at line 119 of file lalinference_pp_pipe.py.

◆ priordagnode

lalinference_pp_pipe.priordagnode = pipeline.CondorDAGManNode(priordagjob)

Definition at line 120 of file lalinference_pp_pipe.py.

◆ pagenode

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

Definition at line 122 of file lalinference_pp_pipe.py.

◆ priorfile

lalinference_pp_pipe.priorfile = pagenode.get_pos_file()

Definition at line 123 of file lalinference_pp_pipe.py.

◆ convertsub

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

Definition at line 126 of file lalinference_pp_pipe.py.

◆ converterr

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

Definition at line 127 of file lalinference_pp_pipe.py.

◆ convertout

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

Definition at line 128 of file lalinference_pp_pipe.py.

◆ injfile

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

Definition at line 131 of file lalinference_pp_pipe.py.

◆ approx

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

Definition at line 134 of file lalinference_pp_pipe.py.

◆ prior2injexe

lalinference_pp_pipe.prior2injexe = prior_cp.get('condor','pos_to_sim_inspiral')

Definition at line 135 of file lalinference_pp_pipe.py.

◆ prior2injjob

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

Definition at line 136 of file lalinference_pp_pipe.py.

◆ prior2injnode

lalinference_pp_pipe.prior2injnode = pipeline.CondorDAGNode(prior2injjob)

Definition at line 143 of file lalinference_pp_pipe.py.

◆ amporder

string lalinference_pp_pipe.amporder = prior_cp.get('engine','amporder')

Definition at line 148 of file lalinference_pp_pipe.py.

◆ maindag

lalinference_pp_pipe.maindag = pipe_utils.LALInferencePipelineDAG(main_cp)

Definition at line 159 of file lalinference_pp_pipe.py.

◆ maindagjob

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

Definition at line 161 of file lalinference_pp_pipe.py.

◆ maindagnode

lalinference_pp_pipe.maindagnode = pipeline.CondorDAGManNode(maindagjob)

Definition at line 162 of file lalinference_pp_pipe.py.

◆ ev

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

Definition at line 165 of file lalinference_pp_pipe.py.

◆ e

lalinference_pp_pipe.e = maindag.add_full_analysis(ev)

Definition at line 166 of file lalinference_pp_pipe.py.

◆ resultspagenodes

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

Definition at line 176 of file lalinference_pp_pipe.py.

◆ posteriorfiles

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

Definition at line 177 of file lalinference_pp_pipe.py.

◆ ppsub

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

Definition at line 180 of file lalinference_pp_pipe.py.

◆ pperr

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

Definition at line 181 of file lalinference_pp_pipe.py.

◆ ppout

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

Definition at line 182 of file lalinference_pp_pipe.py.

◆ ppexe

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

Definition at line 183 of file lalinference_pp_pipe.py.

◆ ppjob

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

Definition at line 184 of file lalinference_pp_pipe.py.

◆ ppnode

lalinference_pp_pipe.ppnode = pipeline.CondorDAGNode(ppjob)

Definition at line 192 of file lalinference_pp_pipe.py.

◆ outdir

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

Definition at line 195 of file lalinference_pp_pipe.py.

Variables

Variable Documentation

◆ usage

◆ parser

◆ default

◆ action

◆ type

◆ help

◆ metavar

◆ None

◆ opts

◆ args

◆ inifile

◆ prior_cp

◆ optionxform

◆ main_cp

◆ rundir

◆ daglogdir

◆ webdir

◆ priordir

◆ maindir

◆ priorwebdir

◆ mainwebdir

◆ outerlogdir

◆ outerdaglog

◆ outerdag

◆ trig_time

◆ fake_event

◆ tfpath

◆ tfile

◆ file

◆ priordag

◆ priordagjob

◆ priordagnode

◆ pagenode

◆ priorfile

◆ convertsub

◆ converterr

◆ convertout

◆ injfile

◆ approx

◆ prior2injexe

◆ prior2injjob

◆ prior2injnode

◆ amporder

◆ maindag

◆ maindagjob

◆ maindagnode

◆ ev

◆ e

◆ resultspagenodes

◆ posteriorfiles

◆ ppsub

◆ pperr

◆ ppout

◆ ppexe

◆ ppjob

◆ ppnode

◆ outdir