B ß‹d¯vã@svdZddlmZdZdZdZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddl mZGd d „d eƒZGd d „d e je jƒZGd d„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd „d eƒZGd!d"„d"eƒZGd#d$„d$eƒZGd%d&„d&eƒZ Gd'd(„d(eƒZ!Gd)d*„d*eƒZ"Gd+d,„d,eƒZ#Gd-d.„d.eƒZ$Gd/d0„d0eƒZ%Gd1d2„d2eƒZ&Gd3d4„d4eƒZ'Gd5d6„d6eƒZ(Gd7d8„d8eƒZ)Gd9d:„d:eƒZ*Gd;d<„d„d>e-ƒZ.Gd?d@„d@e-ƒZ/GdAdB„dBe-ƒZ0GdCdD„dDe-ƒZ1GdEdF„dFe-ƒZ2GdGdH„dHe-ƒZ3GdIdJ„dJe-ƒZ4GdKdL„dLe-ƒZ5GdMdN„dNe-ƒZ6GdOdP„dPe-ƒZ7GdQdR„dRe-ƒZ8GdSdT„dTe-ƒZ9GdUdV„dVe-ƒZ:GdWdX„dXe-ƒZ;GdYdZ„dZe-ƒZGd_d`„d`e-ƒZ?Gdadb„dbe-ƒZ@Gdcdd„dde-ƒZAGdedf„dfe-ƒZBGdgdh„dhe-ƒZCGdidj„dje-ƒZDGdkdl„dleƒZEGdmdn„dne.ƒZFGdodp„dpeƒZGGdqdr„dre.ƒZHGdsdt„dteƒZIGdudv„dve.ƒZJGdwdx„dxeƒZKGdydz„dze.ƒZLGd{d|„d|eƒZMGd}d~„d~e.ƒZNGdd€„d€eƒZOGdd‚„d‚e.ƒZPGdƒd„„d„eƒZQGd…d†„d†e.ƒZRGd‡dˆ„dˆeƒZSGd‰dŠ„dŠe.ƒZTGd‹dŒ„dŒeƒZUGddŽ„dŽe.ƒZVGdd„deƒZWGd‘d’„d’e.ƒZXGd“d”„d”eƒZYGd•d–„d–e-ƒZZGd—d˜„d˜eƒZ[Gd™dš„dše.ƒZ\Gd›dœ„dœe j]ƒZ^Gddž„dže j_ƒZ`GdŸd „d e j]ƒZaGd¡d¢„d¢e j_ƒZbGd£d¤„d¤e j]ƒZcGd¥d¦„d¦e j_ƒZdGd§d¨„d¨e j]ƒZeGd©dª„dªe j_ƒZfGd«d¬„d¬e j]ƒZgGd­d®„d®e j_ƒZhGd¯d°„d°e j]ƒZiGd±d²„d²e j_ƒZjGd³d´„d´e j]ƒZkGdµd¶„d¶e j_ƒZlGd·d¸„d¸e j]ƒZmGd¹dº„dºe j_ƒZnGd»d¼„d¼enƒZoGd½d¾„d¾enƒZpGd¿dÀ„dÀenƒZqGdÁd„dÂe j]ƒZrGdÃdÄ„dÄe j_ƒZsGdÅdÆ„dÆe j]ƒZtGdÇdÈ„dÈe j_ƒZuGdÉdÊ„dÊe j]ƒZvGdËdÌ„dÌe j_ƒZwGdÍd΄dÎe j]ƒZxGdÏdЄdÐe j_ƒZydãdÑdÒ„ZzGdÓdÔ„dÔe j]ƒZ{GdÕdÖ„dÖe j_ƒZ|Gd×dØ„dØe j]ƒZ}GdÙdÚ„dÚe j_ƒZ~GdÛdÜ„dÜeƒZGdÝdÞ„dÞe-ƒZ€Gdßdà„dàeƒZGdádâ„dâe-ƒZ‚dS)äz¤ Classes needed for the inspiral analysis pipeline. This script produced the necessary condor submit and dag files to run the standalone inspiral code on LIGO data é)Úprint_functionz*Duncan Brown z$Date$z $Revision$N)Úpipeline)Úlalc@seZdZddd„ZdS)Ú InspiralErrorNcCs ||_dS)N)Úargs)Úselfr©rú]/work/yifan.wang/ringdown/master-ringdown-env/lib/python3.7/site-packages/lalapps/inspiral.pyÚ__init__szInspiralError.__init__)N)Ú__name__Ú __module__Ú __qualname__r rrrr rsrc@sBeZdZdZddd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dS)ÚInspiralAnalysisJoba0 An inspiral analysis job captures some of the common features of the specific inspiral jobs that appear below. Specifically, the universe and exec_name are set, the stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. Úxmlc CsØ||_||_| dd¡}| d|¡}tj |||¡tj ||¡| dd¡| dd¡|_ t   |¡}x:|D]2}|  |¡rˆ|  ||¡qltd|dtjdqlW| d |d ¡| d |d ¡| |d ¡d S)zµ cp = ConfigParser object from which options are read. sections = sections of the ConfigParser that get added to the opts exec_name = exec_name name in ConfigParser ÚcondorÚuniverseZ copy_to_spoolÚFalsezuse-gpusz)warning: config file is missing section [ú])Úfilezlogs/zB-$(macrogpsstarttime)-$(macrogpsendtime)-$(cluster)-$(process).outzB-$(macrogpsstarttime)-$(macrogpsendtime)-$(cluster)-$(process).errz.subN)Ú_InspiralAnalysisJob__exec_nameÚ_InspiralAnalysisJob__extensionÚgetrÚ CondorDAGJobr Ú AnalysisJobÚadd_condor_cmdÚ has_optionÚ_InspiralAnalysisJob__use_gpusÚcopyÚdeepcopyÚ has_sectionÚ add_ini_optsÚprintÚsysÚstderrÚset_stdout_fileÚset_stderr_fileÚ set_sub_file) rÚcpÚsectionsÚ exec_nameÚ extensionrÚ executableZmycpÚsecrrr r #s$        zInspiralAnalysisJob.__init__cCs ||_dS)z Set the exec_name name N)r)rr)rrr Ú set_exec_nameAsz!InspiralAnalysisJob.set_exec_namecCs|jS)z Get the exec_name name )r)rrrr Ú get_exec_nameGsz!InspiralAnalysisJob.get_exec_namecCs ||_dS)z Set the file extension N)r)rr*rrr Ú set_extensionMsz!InspiralAnalysisJob.set_extensioncCs|jS)z- Get the extension for the file name )r)rrrr Ú get_extensionSsz!InspiralAnalysisJob.get_extensioncCs|jS)zA Get whether this job was requested to run on a GPU node )r)rrrr Ú get_use_gpusYsz InspiralAnalysisJob.get_use_gpusN)r) r r r Ú__doc__r r-r.r/r0r1rrrr rs rc@seZdZdZddd„ZdS)ÚInspiralPlottingJobz{ The InspiralPlottingJob class will assign options common to all plotting jobs. Currently this is only MPLCONFIGDIR. rcCsJt |||||¡| dd¡| dd¡rF| dd¡}| dd|¡dS)zµ cp = ConfigParser object from which options are read. sections = sections of the ConfigParser that get added to the opts exec_name = exec_name name in ConfigParser ÚgetenvÚTruerZ matplotlibdirÚ environmentz MPLCONFIGDIR=N)rr rrr)rr'r(r)r*Z MPLConfigPathrrr r gs    zInspiralPlottingJob.__init__N)r)r r r r2r rrrr r3bsr3c@seZdZdZdd„ZdS)Ú TmpltBankJobaT A lalapps_tmpltbank job used by the inspiral pipeline. The static options are read from the sections [data] and [tmpltbank] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specfied in the ini file. The path to the executable is determined from the ini file. cCsXd}d}ddg}d}| dd¡r2d}| ddd ¡t |||||¡|rT| d d ¡d S) z? cp = ConfigParser object from which options are read. Z tmpltbankrÚdataFÚpycbcTrrÚvanillar4r5N)rÚsetrr r)rr'r)r*r(Ú have_pycbcrrr r }s zTmpltBankJob.__init__N)r r r r2r rrrr r7usr7c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú InspInjJobaI A lalapps_inspinj job used by the grb inspiral pipeline. The static options are read from the section [inspinj] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specified in the ini file. The path to the executable is determined from the ini file. cCs:d}dg}d}t |||||¡| d¡g|_g|_dS)z? cp = ConfigParser object from which options are read. Zinspinjrr:N)rr Z set_universeÚ_InspInjJob__listDoneÚ_InspInjJob__listNodes)rr'r)r(r*rrr r ™s zInspInjJob.__init__cCs|j |¡|j |¡dS)N)r>Úappendr?)rÚnumberÚnoderrr Úset_done¦s zInspInjJob.set_donecCs&|j |¡r"|j |¡}|j|SdS)N)r>ÚcountÚindexr?)rrArErrr Ú check_nodeªs   zInspInjJob.check_nodeN)r r r r2r rCrFrrrr r=‘s r=c@seZdZdZdd„ZdS)Ú BbhInjJobaJ A lalapps_bbhinj job used by the online inspiral pipeline. The static options are read from the section [bbhinj] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specified in the ini file. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)z? cp = ConfigParser object from which options are read. ZbbhinjrN)rr )rr'r)r(r*rrr r ¹szBbhInjJob.__init__N)r r r r2r rrrr rG±srGc@seZdZdZdd„ZdS)Ú RandomBankJobaJ A lalapps_randombank job used by the inspiral pipeline. The static options are read from the section [randombank] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specfied in the ini file. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)z? cp = ConfigParser object from which options are read. Z randombankrN)rr )rr'r)r(r*rrr r ËszRandomBankJob.__init__N)r r r r2r rrrr rHÃsrHc@seZdZdZdd„ZdS)Ú SplitBankJobaH A lalapps_splitbank job used by the inspiral pipeline. The static options are read from the section [splitbank] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specfied in the ini file. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)z? cp = ConfigParser object from which options are read. Z splitbankrN)rr )rr'r)r(r*rrr r ÝszSplitBankJob.__init__N)r r r r2r rrrr rIÕsrIc@seZdZdZdd„ZdS)Ú InspiralJobaÕ A lalapps_inspiral job used by the inspiral pipeline. The static options are read from the sections [data] and [inspiral] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specfied in the ini file. The path to the executable is determined from the ini file. If the user requested GPU utilization, checks are done to ensure a successful run and the necessary Condor commands are added. c Cs2d}ddg}d}d}| dd¡r>d}| ddd ¡| dd¡t |||||¡| d d ¡| d d ¡|rx| dd¡| ¡r.| dd¡}|d kr¦td|dƒ‚| d|¡}t   d¡}t j dd|gdt j d} d} x"| jD]} | | ¡} | ràd} PqàW| s tdƒ‚| dd¡| dd¡| dd¡dS)z? cp = ConfigParser object from which options are read. Úinspiralr8rFr9Trrr:r6z!KMP_LIBRARY=serial;MKL_SERIAL=yesÚrequest_memoryZ1000r4r5z'Cannot run GPU inspiral jobs on Condor z universe. Please use vanilla.z'^\s*NEEDED\s*(libcufft\.|libcudart\.).*Úobjdumpz-pN)ÚstdinÚstdoutzNInspiral executable has no CUDA dependencies. Please use a CUDA-enabled build.z gpu-device-idÚ0z+WantGPUÚtrueZ Requirementsz( GPU_PRESENT =?= true))rr;Ú remove_optionrr rr1rÚ RuntimeErrorÚreÚcompileÚ subprocessÚPopenÚPIPErOÚmatchÚadd_opt) rr'r)r(r*r<rr+Z objdump_reÚprocZ cuda_depsÚlineÚmrrr r ñsB               zInspiralJob.__init__N)r r r r2r rrrr rJçs rJc@seZdZdZdd„ZdS)ÚInspiralCkptJobaj A lalapps_inspiral job used by the inspiral pipeline. The static options are read from the sections [data] and [inspiral] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specfied in the ini file. The path to the executable is determined from the ini file. This one checkpoints. cCs.d}g}d}t |||||¡| dd¡dS)z? cp = ConfigParser object from which options are read. rKrZ_condor_relocatableÚN)rr Z add_short_opt)rr'r)r(r*rrr r )s zInspiralCkptJob.__init__N)r r r r2r rrrr r^ sr^c@seZdZdZdd„ZdS)ÚPTFInspiralJobaR A lalapps_inspiral job used by the inspiral pipeline. The static options are read from the sections [data] and [inspiral] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specfied in the ini file. The path to the executable is determined from the ini file. cCs^d}dg}d}t |||||¡d}| d¡rJ| dd¡rJt| dd¡ƒ}| dd|¡dS) z? cp = ConfigParser object from which options are read. Zcoh_PTF_inspiralrinzcoh_PTF_inspiral-metaz minimum-ramrLz%dN)rr rrÚintrr)rr'r)r(r*ZramValuerrr r <s  zPTFInspiralJob.__init__N)r r r r2r rrrr r`4sr`c@seZdZdZdd„ZdS)Ú TrigbankJoba? A lalapps_trigbank job used by the inspiral pipeline. The static options are read from the section [trigbank] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job always runs in the scheduler universe. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)z? cp = ConfigParser object from which options are read. ZtrigbankrN)rr )rr'r)r(r*rrr r SszTrigbankJob.__init__N)r r r r2r rrrr rbKsrbc@seZdZdZdd„ZdS)ÚIncaJoba A lalapps_inca job used by the inspiral pipeline. The static options are read from the section [inca] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)z? cp = ConfigParser object from which options are read. ZincarN)rr )rr'r)r(r*rrr r dszIncaJob.__init__N)r r r r2r rrrr rc]srcc@s eZdZdZdd„Zdd„ZdS)Ú ThincaJoba  A lalapps_thinca job used by the inspiral pipeline. The static options are read from the section [thinca] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs8d}g}d}t |||||¡| d¡r4| |d¡dS)z? cp = ConfigParser object from which options are read. ZthincarN)rr rr )rr'r)r(r*rrr r us  zThincaJob.__init__cCsÌxÆ| |¡D]¸}t | ||¡¡}|dd…dkr¸tj |¡d}|t d¡krªy(t |tj |¡d¡|  ||¡Wq¶t d|dt j d|  ||¡Yq¶XqÄ|  ||¡q |  ||¡q WdS) zè Parse command line options from a given section in an ini file and pass to the executable. @param cp: ConfigParser object pointing to the ini file. @param section: section of the ini file to add to the options. éüÿÿÿNréÿÿÿÿÚ.zsym link failed for z grid workflows might be broken)r)ÚoptionsÚstringÚstriprÚosÚpathÚsplitÚlistdirÚsymlinkÚ add_file_optr!r"r#rZ)rr'ÚsectionÚoptÚargÚfnamerrr r ‚szThincaJob.add_ini_optsN)r r r r2r r rrrr rdns rdc@s@eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dS)ÚThincaToCoincJobzl A ThincaToCoinc job. The static options are read from the section [thinca_to_coinc] in the ini file. cCs`d}dg}d}t |||||¡| dd¡d|_d|_| d|d¡| d|d¡dS) zE @param cp: ConfigParser object from which options are read. Zthinca_to_coincrr4r5Nzlogs/z-$(cluster)-$(process).outz-$(cluster)-$(process).err)rr rÚ(_ThincaToCoincJob__experiment_start_timeÚ&_ThincaToCoincJob__experiment_end_timer$r%)rr'r)r(r*rrr r  s zThincaToCoincJob.__init__cCs| d|¡||_dS)z± Sets the experiment-start-time option. This is a required option. @param experiment_start_time: gps start time of the experiment the thinca_to_coinc job is in. zexperiment-start-timeN)rZrv)rÚexperiment_start_timerrr Úset_experiment_start_time¯s z*ThincaToCoincJob.set_experiment_start_timecCs| d|¡||_dS)z« Sets the experiment-end-time option. This is a required option. @param experiment_end_time: gps end time of the experiment the thinca_to_coinc job is in. zexperiment-end-timeN)rZrw)rÚexperiment_end_timerrr Úset_experiment_end_time¸s z(ThincaToCoincJob.set_experiment_end_timecCs|jS)z@ Returns the value of the experiment-start-time option. )rv)rrxrrr Úget_experiment_start_timeÁsz*ThincaToCoincJob.get_experiment_start_timecCs|jS)z> Returns the value of the experiment-end-time option. )rv)rrzrrr Úget_experiment_end_timeÇsz(ThincaToCoincJob.get_experiment_end_timecCs| dd¡dS)z2 Adds the simulation argument to the job. Z simulationr_N)rZ)rrrr Úset_simulationÍszThincaToCoincJob.set_simulationN) r r r r2r ryr{r|r}r~rrrr ru›s  ruc@seZdZdZdd„ZdS)Ú HWinjPageJobz] A HWinjPageJob, runs the hardware injection page script on the output of the pipeline cCs|d}d}d}d}| d|¡}tj |||¡tj ||¡| dd¡| d|d ¡| d|d ¡| |d ¡d S) zE @param cp: ConfigParser object from which options are read. Zhardware_inj_pager:z[hardware-injection-page]Úhtmlrr4r5zlogs/z-$(cluster)-$(process).outz-$(cluster)-$(process).errz.subN) rrrr rrr$r%r&)rr'r)rr(r*r+rrr r Øs  zHWinjPageJob.__init__N)r r r r2r rrrr rÓsrc@seZdZdZdd„ZdS)ÚSireJobz¾ A lalapps_sire job used by the inspiral pipeline. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs8d}dg}d}t |||||¡| d¡| d¡dS)zF @param cp = ConfigParser object from which options are read. Zsirerz/logs/sire-$(macroifo)-$(cluster)-$(process).outz/logs/sire-$(macroifo)-$(cluster)-$(process).errN)rr r$r%)rr'r)r(r*rrr r îs  zSireJob.__init__N)r r r r2r rrrr rèsrc@seZdZdZdd„ZdS)ÚCoireJobz¿ A lalapps_coire job used by the inspiral pipeline. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs8d}dg}d}t |||||¡| d¡| d¡dS)zF @param cp = ConfigParser object from which options are read. Zcoirerz0logs/coire-$(macroifo)-$(cluster)-$(process).outz0logs/coire-$(macroifo)-$(cluster)-$(process).errN)rr r$r%)rr'r)r(r*rrr r s  zCoireJob.__init__N)r r r r2r rrrr r‚üsr‚c@seZdZdZdd„ZdS)Ú FrJoinJobzw A lalapps_frjoin job used by the inspiral pipeline. The path to the executable is determined from the ini file. cCs6d}g}d}t |||||¡| d¡| d¡dS)zF @param cp = ConfigParser object from which options are read. ZfrjoinZgwfz%logs/frjoin-$(cluster)-$(process).outz%logs/frjoin-$(cluster)-$(process).errN)rr r$r%)rr'r)r(r*rrr r s  zFrJoinJob.__init__N)r r r r2r rrrr rƒsrƒc@seZdZdZdd„ZdS)Ú CohBankJoba A lalapps_coherent_inspiral job used by the inspiral pipeline. The static options are read from the section [cohbank] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. ZcohbankrN)rr )rr'r)r(r*rrr r *szCohBankJob.__init__N)r r r r2r rrrr r„#sr„c@seZdZdZdd„ZdS)ÚInspiralCoherentJobaR A lalapps_inspiral job used by the inspiral pipeline. The static options are read from the sections [data] and [inspiral] in the ini file. The stdout and stderr from the job are directed to the logs directory. The job runs in the universe specfied in the ini file. The path to the executable is determined from the ini file. cCs0d}dg}d}t |||||¡| dd¡dS)zF @param cp = ConfigParser object from which options are read. rKr8rr6z!KMP_LIBRARY=serial;MKL_SERIAL=yesN)rr r)rr'r)r(r*rrr r <s zInspiralCoherentJob.__init__N)r r r r2r rrrr r…4sr…c@seZdZdZdd„ZdS)ÚCohInspBankJoba A lalapps_coherent_inspiral job used by the inspiral pipeline. The static options are read from the section [cohinspbank] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. Z cohinspbankrN)rr )rr'r)r(r*rrr r NszCohInspBankJob.__init__N)r r r r2r rrrr r†Gsr†c@seZdZdZdd„ZdS)ÚChiaJoba A lalapps_coherent_inspiral job used by the inspiral pipeline. The static options are read from the section [chia] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. ZchiarN)rr )rr'r)r(r*rrr r _szChiaJob.__init__N)r r r r2r rrrr r‡Xsr‡c@seZdZdZdd„ZdS)Ú CohireJobzÀ A lalapps_cohire job used by the inspiral pipeline. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs8d}dg}d}t |||||¡| d¡| d¡dS)zF @param cp = ConfigParser object from which options are read. Zcohirerz1logs/cohire-$(macroifo)-$(cluster)-$(process).outz1logs/cohire-$(macroifo)-$(cluster)-$(process).errN)rr r$r%)rr'r)r(r*rrr r os  zCohireJob.__init__N)r r r r2r rrrr rˆisrˆc@seZdZdZdd„ZdS)Ú InjFindJobz^ An injfind job. The static options are read from the [injfind] section in the cp file. cCsTd}dg}d}t |||||¡| dd¡| d|d¡| d|d¡dS) zK @param cp: a ConfigParser object from which the options are read. Zinjfindrr4r5zlogs/z-$(cluster)-$(process).outz-$(cluster)-$(process).errN)rr rr$r%)rr'r)r(r*rrr r ‚s zInjFindJob.__init__N)r r r r2r rrrr r‰}sr‰c@sheZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„ZdS)ÚInspiralAnalysisNodezL An InspiralNode runs an instance of the inspiral code in a Condor DAG. cCs\tj ||¡tj |¡| ¡}d|krHt|dƒrH| t|dƒ¡d|k|_d|_dS)zL job = A CondorDAGJob that can run an instance of lalapps_inspiral. zpad-datazwrite-compressFN) rÚ CondorDAGNoder Ú AnalysisNodeZget_optsraZ set_pad_dataÚ!_InspiralAnalysisNode__zip_outputÚ&_InspiralAnalysisNode__data_checkpoint)rÚjobÚoptsrrr r —s  zInspiralAnalysisNode.__init__cCs ||_dS)z! Set the zip output flag N)r)rÚziprrr Úset_zip_output¥sz#InspiralAnalysisNode.set_zip_outputcCs|jS)z! Set the zip output flag )r)rrrr Úget_zip_output«sz#InspiralAnalysisNode.get_zip_outputcCsœ| ¡r| ¡r| ¡s tdƒ‚| ¡d| ¡ ¡ ¡}| ¡rT|d| ¡7}| ¡rl|d| ¡7}|dt | ¡ƒdt | ¡| ¡ƒ7}|S)zº Returns the base file name of output from the inspiral code. This is assumed to follow the standard naming convention: IFO-EXECUTABLE_IFOTAG_USERTAG-GPS_START-DURATION z,Start time, end time or ifo has not been setú-Ú_) Ú get_startÚget_endÚget_iforrr.ÚupperÚ get_ifo_tagÚ get_user_tagÚstr)rZfilebaserrr Úget_output_base±sz$InspiralAnalysisNode.get_output_basecCsD| ¡}|d| ¡ ¡7}| ¡r,|d7}|jdkr@| |¡|S)z› Returns the file name of output from the inspiral code. This is obtained from the get_output_base() method, with the correct extension added. rgz.gzF)rrr0r“rŽÚadd_output_file)rÚfilenamerrr Ú get_outputÇs  zInspiralAnalysisNode.get_outputcCs| ¡}|d7}| |¡|S)z¦ Returns the file name of condor checkpoint from the inspiral code. This is obtained from the get_output_base() method, with the correct extension added. z.ckpt)rrž)rrŸrrr Úget_checkpoint_image×s z)InspiralAnalysisNode.get_checkpoint_imagecCs| dd¡d|_dS)z9 Lets it be known that data checkpointing exists zdata-checkpointr_TN)Ú add_var_optrŽ)rrrr Úset_data_checkpointãs z(InspiralAnalysisNode.set_data_checkpointcCs|jS)z9 Lets it be known that data checkpointing exists )rŽ)rrrr Úget_data_checkpointêsz(InspiralAnalysisNode.get_data_checkpointcCs| ¡}|d7}dS)z³ Returns the name of the cache file output from the inspiral analysis codes. This is obtained from the get_output_base() method, with the correct extension added. z.cacheN)r)rrŸrrr Úget_output_cacheðsz%InspiralAnalysisNode.get_output_cachecCs| ¡}|d7}| |¡|S)zG Returns the file name of output frame from the inspiral code. z.gwf)rrž)rZgwffilerrr Ú get_froutputùs z!InspiralAnalysisNode.get_froutputcCs8| ¡r4| | ¡| ¡¡| | ¡| ¡¡dS)z3 set the data_start_time and data_end_time N)Z get_pad_dataZset_data_startr–Z set_data_endr—)rrrr Úfinalizes    zInspiralAnalysisNode.finalizeN)r r r r2r r’r“rr r¡r£r¤r¥r¦r§rrrr rŠ“s   rŠc@seZdZdZdd„ZdS)ÚInspiralPlottingNodez_ An InspiralPlottingNode runas an instance of the inspiral plotting code in a Condor Dag cCst ||¡dS)zL job = A CondorDAGJob that can run an instance of the plotting code N)rŠr )rrrrr r szInspiralPlottingNode.__init__N)r r r r2r rrrr r¨sr¨c@s8eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd S) Ú InspInjNodezU A InspInjNode runs an instance of the inspinj generation job in a Condor DAG. cCst ||¡d|_d|_dS)zK job = A CondorDAGJob that can run an instance of lalapps_inspinj. N)rŠr Ú_InspInjNode__outputNameÚ_InspInjNode__seed)rrrrr r "s zInspInjNode.__init__cCs| d|¡||_dS)z Set the seed of the injection file by setting a --seed option to the node when it is executed. @param seed: seed of the job ÚseedN)r¢r«)rr¬rrr Úset_seed*s zInspInjNode.set_seedcCs|jS)z return the seed )r«)rrrr Úget_seed3szInspInjNode.get_seedcCs| d|¡||_dS)zm Set the output name of the injection file @param outputName: name of the injection file created ÚoutputN)r¢rª)rÚ outputNamerrr Ú set_output9s zInspInjNode.set_outputcCs‚|jr| |j¡|jSdt| ¡ƒ}| ¡r@|d| ¡7}|dt| ¡ƒdt| ¡| ¡ƒd7}| |¡|SdS)z| Return the manually-set output name if it exists, otherwise, derive the name like other InspiralAnalysisNodes. zHL-INJECTIONS_r•r”z.xmlN)rªržrœr®r›r–r—)rZ outputFilerrr r As . zInspInjNode.get_outputN) r r r r2r r­r®r±r rrrr r©s  r©c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú BbhInjNodezS A BbhInjNode runs an instance of the bbhinj generation job in a Condor DAG. cCst ||¡dS)zJ job = A CondorDAGJob that can run an instance of lalapps_bbhinj. N)rŠr )rrrrr r XszBbhInjNode.__init__cCs| d|¡||_dS)z Set the seed of the injection file by setting a --seed option to the node when it is executed. @param seed: seed of the job r¬N)r¢Ú_BbhInjNode__seed)rr¬rrr r­^s zBbhInjNode.set_seedcCsê| ¡r| ¡stdƒ‚| ¡rbd| ¡d}|t| ¡ƒd}|t| ¡| ¡ƒd}nz|jr¬dt|jƒd}|t| ¡ƒd}|t| ¡| ¡ƒd}n0dt| ¡ƒd}|t| ¡| ¡ƒd}| |¡|S)zž Returns the file name of output from the injection generation code. This must be kept synchronized with the name of the output file in bbhinj.c. z'Start time or end time has not been setzHL-INJECTIONS_r”z.xmlzHL-INJECTIONS-)r–r—rr›rœr³rž)rZ bbhinjectrrr r gs zBbhInjNode.get_outputN)r r r r2r r­r rrrr r²Ss r²c@seZdZdZdd„ZdS)Ú TmpltBankNodez] A TmpltBankNode runs an instance of the template bank generation job in a Condor DAG. cCst ||¡dS)zM job = A CondorDAGJob that can run an instance of lalapps_tmpltbank. N)rŠr )rrrrr r „szTmpltBankNode.__init__N)r r r r2r rrrr r´sr´c@s eZdZdZdd„Zdd„ZdS)ÚRandomBankNodez\ A RandomBankNode runs an instance of the random bank generation job in a Condor DAG. cCst ||¡dS)zN job = A CondorDAGJob that can run an instance of lalapps_randombank. N)rŠr )rrrrr r szRandomBankNode.__init__cCs€| ¡r| ¡stdƒ‚| ¡rBd| ¡d}|t| ¡ƒ}ndt| ¡ƒ}|dt| ¡| ¡ƒd}| |¡|S)z› Returns the file name of output from the template bank code. This must be kept synchronized with the name of the output file in randombank.c. z'Start time or end time has not been setz P-TMPLTBANK_r”z P-TMPLTBANK-z.xml)r–r—rr›rœrž)rÚbankrrr r –s  zRandomBankNode.get_outputN)r r r r2r r rrrr rµ‹srµc@s@eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dS)Ú SplitBankNodezX A SplitBankNode runs an instance of the split template bank job in a Condor DAG. cCst ||¡d|_d|_dS)zM job = A CondorDAGJob that can run an instance of lalapps_tmpltbank. N)rŠr Ú_SplitBankNode__bankfileÚ_SplitBankNode__numbanks)rrrrr r ®s zSplitBankNode.__init__cCs | d|¡| |¡||_dS)Nz bank-file)r¢Úadd_input_filer¸)rr¶rrr Úset_bank¶s  zSplitBankNode.set_bankcCs|jS)N)r¸)rrrr Úget_bank»szSplitBankNode.get_bankcCs| d|¡t|ƒ|_dS)Nznumber-of-banks)r¢rar¹)rZnumbanksrrr Ú set_num_banks¾s zSplitBankNode.set_num_bankscCs|jS)N)r¹)rrrr Ú get_num_banksÂszSplitBankNode.get_num_banksc Csp| ¡r| ¡stdƒ‚g}|j d¡}xBtdt| ¡ƒƒD],}| d|d|d||d|df¡q|d kr |r˜| d d¡d |_n|d kr¾|r¸| d d¡d |_dS)zµ Add the interferometer to the list of ifos ifo = IFO code (e.g. G1,L1,V1,T1, H1 or H2). pass_to_command_line = boolean for adding ifo-triggers as a variable option ÚG1z g1-triggersr_ÚH1z h1-triggersÚH2z h2-triggersÚL1z l1-triggersÚT1z t1-triggersÚV1z v1-triggersN)r¢rérêrërìrírî)rrÙZpass_to_command_linerrr rÜìs0      zThincaNode.set_ifocCs|jS)z% Returns the IFO code of g1. )ré)rrrr Ú get_ifo_g1 szThincaNode.get_ifo_g1cCs|jS)z% Returns the IFO code of h1. )rê)rrrr Ú get_ifo_h1szThincaNode.get_ifo_h1cCs|jS)z% Returns the IFO code of h2. )rë)rrrr Ú get_ifo_h2szThincaNode.get_ifo_h2cCs|jS)z% Returns the IFO code of l1. )rì)rrrr Ú get_ifo_l1szThincaNode.get_ifo_l1cCs|jS)z% Returns the IFO code of t1. )rí)rrrr Ú get_ifo_t1%szThincaNode.get_ifo_t1cCs|jS)z% Returns the IFO code of v1. )rî)rrrr Ú get_ifo_v1+szThincaNode.get_ifo_v1cCs€d}| ¡r|| ¡7}| ¡r,|| ¡7}| ¡r@|| ¡7}| ¡rT|| ¡7}| ¡rh|| ¡7}| ¡r||| ¡7}|S)z+ Returns the ordered list of ifos. r_)rör÷rørùrúrû)rÚifosrrr Úget_ifos1s      zThincaNode.get_ifoscCs| d|¡||_dS)z0 Set number of time slides to undertake z num-slidesN)r¢rï)rÚ num_slidesrrr Úset_num_slidesEs zThincaNode.set_num_slidescCs|jS)zF Returns the num_slides from .ini (>0 => time slides desired) )rï)rrrr Úget_num_slidesLszThincaNode.get_num_slidescCsâ| ¡r| ¡r| ¡s tdƒ‚|jrH| ¡d| ¡ ¡ ¡d}n| ¡d| ¡ ¡ ¡}| ¡r||d| ¡7}|  ¡r”|d|  ¡7}|dt | ¡ƒdt | ¡| ¡ƒd}|  ¡rÔ|d7}|  |¡|S)zˆ Returns the file name of output from thinca. This must be kept synchronized with the name of the output file in thinca.c. z.Start time, end time or ifos have not been setr”Ú_SLIDEr•z.xmlz.gz) r–r—rýrrïrr.r™ršr›rœr“rž)rrårŸrrr r Rs"0 zThincaNode.get_outputN)T)r r r r2r rÜrör÷rørùrúrûrýrÿrr rrrr rèÚs !rèc@s€eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„ZdS)ÚThincaToCoincNodezL A ThincaToCoincNode runs an instance of a ThincaToCoincJob in a DAG. cCs4t ||¡d|_d|_d|_d|_d|_d|_dS)z) @param job: A ThincaToCoincJob. N)rŠr Ú_ThincaToCoincNode__input_cacheÚ_ThincaToCoincNode__instrumentsÚ!_ThincaToCoincNode__zero_lag_fileÚ#_ThincaToCoincNode__time_slide_fileÚ!_ThincaToCoincNode__veto_segmentsÚ&_ThincaToCoincNode__veto_segments_name)rrrrr r ts zThincaToCoincNode.__init__cCs| d|¡||_dS)zP @param input_cache_name: cache file for thinca_to_coinc to read. z ihope-cacheN)rpr)rÚinput_cache_namerrr Úset_input_cache€s z!ThincaToCoincNode.set_input_cachecCs|jS)z1 Returns input cache file for this node. )r)rrrr Úget_input_cacheˆsz!ThincaToCoincNode.get_input_cachecCsB|jstdƒ‚t|jdƒ}t ¡ |¡j|d}dd„|Dƒ}|S)aJ Returns a list of files that this node will generate using the input_cache. The output file names are the same as the input urls, but with the zero_lag 'THINCA' file replaced with 'THINCA_TO_COINC', and with the filepaths pointing to the current directory in which the thinca_to_coinc node is being run. zno input-cache specifiedÚr)Ú descriptionc Ss2g|]*}d t ¡t ddtj |j¡¡g¡‘qS)ú/ZINCAZ INCA_TO_COINC)ÚjoinrkÚgetcwdrTÚsubrlråÚurl)Ú.0Úentryrrr ú œsz;ThincaToCoincNode.get_output_from_cache..)rÚ ValueErrorÚopenrÚCacheÚfromfileÚsieve)rZcoinc_file_tagÚfpÚ input_cacheZ output_filesrrr Úget_output_from_cacheŽs z'ThincaToCoincNode.get_output_from_cachecCs| d|¡||_dS)zp @param instruments: instruments that are on for the THINCA files thinca_to_coinc is operating on. Ú instrumentsN)r¢r)rrrrr Úset_instruments¡s z!ThincaToCoincNode.set_instrumentscCs|jS)z, Returns instruments for this node. )r)rrrr Úget_instruments©sz!ThincaToCoincNode.get_instrumentscCs| d|¡||_dS)zO @param veto_segments: name of xml file containing the vetoes to apply z veto-segmentsN)r¢r)rZ veto_segmentsrrr Úset_veto_segments¯s z#ThincaToCoincNode.set_veto_segmentscCs|jS)zC Returns the name of the veto-segments file for this node. )r)rrrr Úget_veto_segments¶sz#ThincaToCoincNode.get_veto_segmentscCs| d|¡||_dS)zX @param veto_segments_name: name of vetoes in the vetoes xml file to apply. zveto-segments-nameN)r¢r)rZveto_segments_namerrr Úset_veto_segments_name¼s z(ThincaToCoincNode.set_veto_segments_namecCs|jS)z? Returns the name of the vetoes applied for this node. )r)rrrr Úget_veto_segments_nameÄsz(ThincaToCoincNode.get_veto_segments_namecCs| d|¡||_dS)z' Sets zero_lag_file for input. z zero-lag-fileN)rpr)rZ zero_lag_filerrr Úset_zero_lag_fileÊs z#ThincaToCoincNode.set_zero_lag_filecCs|jS)z Returns zero_lag_file. )r)rrrr Úget_zero_lag_fileÑsz#ThincaToCoincNode.get_zero_lag_filecCs| d|¡||_dS)z- Sets the time_slide_file for input. ztime-slide-fileN)rpr)rZtime_slide_filerrr Úset_time_slide_file×s z%ThincaToCoincNode.set_time_slide_filecCs|jS)z& Returns the time_slide_file. )r)rrrr Úget_time_slide_fileÞsz%ThincaToCoincNode.get_time_slide_fileN)r r r r2r r r rrr r!r"r#r$r%r&r'r(rrrr ros rc@s@eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dS)Ú HWinjPageNodezD A HWinjPageNode runs an instance of a HWinjPageJob in a DAG. cCs.t ||¡d|_d|_d|_d|_d|_dS)z% @param job: A HWinjPageJob. N)rŠr Ú_HWinjPageNode__input_cacheÚ_HWinjPageNode__cache_stringÚ_HWinjPageNode__outfileZ_HWinjPageNode__segment_dirÚ_HWinjPageNode__source_xml)rrrrr r és  zHWinjPageNode.__init__cCs| d|¡||_dS)z[ @param input_cache_name: cache file for ligolw_cbc_hardware_inj_page to read. z cache-fileN)r¢r*)rr rrr r ôs zHWinjPageNode.set_input_cachecCs| d|¡||_dS)zP input_cache_name: cache file for ligolw_cbc_hardware_inj_page to read. z source-xmlN)r¢r-)rZ source_xmlrrr Úset_source_xmlüs zHWinjPageNode.set_source_xmlcCs| d|¡||_dS)zB @param cache_string: pattern to match files within cache z cache-patternN)r¢r+)rÚ cache_stringrrr Úset_cache_strings zHWinjPageNode.set_cache_stringcCs| d|¡||_dS)z8 @param outfile_name: Name of hw injection page rÍN)r¢r,)rZ outfile_namerrr Úset_output_file s zHWinjPageNode.set_output_filecCs| d|¡dS)z? @param dir: directory in which to find hwinj segments z segment-dirN)r¢)rÚdirrrr Úset_segment_dirszHWinjPageNode.set_segment_dirN) r r r r2r r r.r0r1r3rrrr r)äs r)c@s€eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„ZdS)ÚSireNodezW A SireNode runs an instance of the single inspiral reader code in a Condor DAG. cCst ||¡d|_d|_dS)zH job = A CondorDAGJob that can run an instance of lalapps_sire. N)rŠr Ú_SireNode__injection_fileÚ_SireNode__ifo_tag)rrrrr r s zSireNode.__init__cCs||_| d|¡dS)z) Add the list of interferometers zifo-cutN)Ú_SireNode__ifor¢)rrÙrrr rÜ$szSireNode.set_ifocCs|jS)z8 Returns the two letter IFO code for this node. )r7)rrrr r˜+szSireNode.get_ifocCs||_| d|¡dS)z! Sets the injection file zinjection-fileN)r5r¢)rrrrr Ú set_inj_file1szSireNode.set_inj_filecCs|jS)z! Gets the injection file )r5)rrrr Ú get_inj_file8szSireNode.get_inj_filecCs ||_dS)z Sets GPS start time N)Ú_SireNode__start)rÚstartrrr Ú set_start>szSireNode.set_startcCs|jS)z Gets GPS start time )r:)rrrr r–DszSireNode.get_startcCs ||_dS)z Sets GPS end time N)Ú_SireNode__end)rÚendrrr Úset_endJszSireNode.set_endcCs|jS)z Gets GPS end time )r=)rrrr r—PszSireNode.get_endcCs ||_dS)zx Set the ifo tag that is passed to the analysis code. @param ifo_tag: a string to identify one or more IFOs N)r6)rÚifo_tagrrr Ú set_ifo_tagVszSireNode.set_ifo_tagcCs|jS)z$ Returns the IFO tag string )r6)rrrr rš]szSireNode.get_ifo_tagcCsâ| ¡stdƒ‚| ¡d}| ¡rF|d| ¡ d¡d7}|d7}| ¡r^|d| ¡7}| ¡rv|d| ¡7}| ¡r†| ¡r–| ¡rž| ¡sžtdƒ‚| ¡rÖ| ¡| ¡}|dt| ¡ƒdt|ƒ7}|d7}|S) z) get the name of the output file zifos have not been setz-SIREr•r”r¿Ú_FOUNDz,If one of start and end is set, both must bez.xml) r˜rr9rmršr›r–r—rœ)rrtÚdurationrrr r cs$  zSireNode.get_outputcCs | ¡r| ¡ dd¡SdSdS)z) get the name of the missed file ÚFOUNDÚMISSEDN)r9r Úreplace)rrrr Ú get_missed~szSireNode.get_missedcCs`| ¡}|jd|dd|jd| dd¡dd| ¡r\| d| ¡¡|jd| ¡ddd S) z set the output options r¯T)Úfile_is_output_fileÚsummaryrÚtxtzinjection-filezmissed-injectionsN)r rprFr9rG)rr¯rrr r§‡s zSireNode.finalizeN)r r r r2r rÜr˜r8r9r<r–r?r—rAršr rGr§rrrr r4s r4c@s eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Zd$d%„Zd&S)'Ú CoireNodezP A CoireNode runs an instance of the inspiral coire code in a Condor DAG. cCs.t ||¡d|_d|_d|_d|_d|_dS)zI job = A CondorDAGJob that can run an instance of lalapps_coire. N)rŠr Ú_CoireNode__ifosÚ_CoireNode__ifo_tagÚ_CoireNode__num_slidesÚ_CoireNode__injection_fileÚ_CoireNode__output_tag)rrrrr r ™s  zCoireNode.__init__cCs ||_dS)z) Add the list of interferometers N)rL)rrürrr Úset_ifos¤szCoireNode.set_ifoscCs|jS)z Returns the ifos )rL)rrrr rýªszCoireNode.get_ifoscCs||_| d|¡dS)z' Add the number of time slides z num-slidesN)rNr¢)rÚslidesrrr Ú set_slides°szCoireNode.set_slidescCs|jS)z& Returns the number of slides )rN)rrrr Ú get_slides·szCoireNode.get_slidescCs|r||_| d|¡dS)z! Sets the injection file zinjection-fileN)rOr¢)rrrrr r8½szCoireNode.set_inj_filecCs|jS)z! Gets the injection file )rO)rrrr r9ÅszCoireNode.get_inj_filecCs ||_dS)z Sets GPS start time N)Ú_CoireNode__start)rr;rrr r<ËszCoireNode.set_startcCs|jS)z Gets GPS start time )rU)rrrr r–ÑszCoireNode.get_startcCs ||_dS)z Sets GPS end time N)Ú_CoireNode__end)rr>rrr r?×szCoireNode.set_endcCs|jS)z Gets GPS end time )rV)rrrr r—ÝszCoireNode.get_endcCs ||_dS)zx Set the ifo tag that is passed to the analysis code. @param ifo_tag: a string to identify one or more IFOs N)rM)rr@rrr rAãszCoireNode.set_ifo_tagcCs|jS)z$ Returns the IFO tag string )rM)rrrr ršêszCoireNode.get_ifo_tagcCs˜| ¡ ¡ ¡}| ¡r |d7}| ¡r^|d| ¡ d¡d d¡d d¡d7}|d 7}| ¡rv|d| ¡7}| ¡rŽ|d| ¡7}||_dS) Nrr•rrfrgrr”r¿rB) rr.r™rTr9rmršr›rP)rrtrrr Úset_output_tagðs*zCoireNode.set_output_tagcCs|jS)N)rP)rrrr Úget_output_tagûszCoireNode.get_output_tagcCs˜| ¡stdƒ‚| ¡| ¡d| ¡}| ¡r<| ¡rL| ¡rT| ¡sTtdƒ‚| ¡rŒ| ¡| ¡}|dt| ¡ƒdt|ƒ7}|d7}|S)z) get the name of the output file zifos have not been setr”z,If one of start and end is set, both must bez.xml)rýrrWrXr–r—rœ)rrtrCrrr r þs zCoireNode.get_outputcCs | ¡r| ¡ dd¡SdSdS)z) get the name of the missed file rDrEN)r9r rF)rrrr rGszCoireNode.get_missedcCs`| ¡}|jd|dd|jd| dd¡dd| ¡r\| d| ¡¡|jd| ¡ddd S) z set the output options r¯T)rHrIrrJzinjection-filezmissed-injectionsN)r rprFr9rG)rr¯rrr r§s zCoireNode.finalizeN)r r r r2r rQrýrSrTr8r9r<r–r?r—rAršrWrXr rGr§rrrr rK”s&   rKc@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú FrJoinNodezE A FrJoinNode runs an instance of lalapps_frjoin in a Condor DAG cCst ||¡dS)zJ job = A CondorDAGJob that can run an instance of lalapps_frjoin. N)rŠr )rrrrr r 0szFrJoinNode.__init__cCs&| d|¡|jd|dd||_dS)zi Set the output name of the frame file @param outputName: name of the injection file created r¯T)rHN)r¢rpÚ_FrJoinNode__outputName)rr°rrr r±6s zFrJoinNode.set_outputcCs|jS)z/ Get the output name of the frame file )rZ)rrrr r ?szFrJoinNode.get_outputN)r r r r2r r±r rrrr rY,s rYc@sPeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dS)Ú CohBankNodezJ A CohBankNode runs an instance of the coherent code in a Condor DAG. cCst ||¡d|_d|_dS)zU job = A CondorDAGJob that can run an instance of lalapps_coherent_inspiral. N)rŠr Ú_CohBankNode__bankÚ_CohBankNode__ifos)rrrrr r Js zCohBankNode.__init__cCs | d|¡| |¡||_dS)Nz bank-file)r¢rºr\)rr¶rrr r»Rs  zCohBankNode.set_bankcCs|jS)N)r\)rrrr r¼WszCohBankNode.get_bankcCsª|dkr| dd¡d|_nŠ|dkr8| dd¡d|_nn|dkrT| dd¡d|_nR|dkrp| d d¡d|_n6|d krŒ| d d¡d |_n|d kr¦| d d¡d |_dS)z_ Add the interferometer to the list of ifos ifo = IFO code (e.g. G1,L1, H1 or H2). rðz g1-triggersr_rñz h1-triggersròz h2-triggersróz l1-triggersrôz t1-triggersrõz v1-triggersN)r¢Z_CohBankNode__ifo_g1Z_CohBankNode__ifo_h1Z_CohBankNode__ifo_h2Z_CohBankNode__ifo_l1Z_CohBankNode__ifo_t1Z_CohBankNode__ifo_v1)rrÙrrr rÜZs$      zCohBankNode.set_ifocCs| d|¡||_dS)Nrü)r¢r])rrürrr rQrs zCohBankNode.set_ifoscCs|jS)N)r])rrrr rývszCohBankNode.get_ifoscCs| d|¡||_dS)z0 Set number of time slides to undertake z num-slidesN)r¢Z_CohBankNode__num_slides)rrþrrr rÿys zCohBankNode.set_num_slidescCs‚| ¡stdƒ‚| ¡d}| ¡r4|d| ¡7}|dt| ¡ƒdt| ¡| ¡ƒd}| ¡rt|d7}| |¡|S)zA Returns the file name of output from the coherent bank. zIfos have not been setz-COHBANKr•r”z.xmlz.gz)rýrr›rœr–r—r“rž)rrårŸrrr r €s 0 zCohBankNode.get_outputN) r r r r2r r»r¼rÜrQrýrÿr rrrr r[Fsr[c@sHeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dS)ÚCohInspBankNodezJ A CohBankNode runs an instance of the coherent code in a Condor DAG. cCst ||¡d|_d|_dS)zU job = A CondorDAGJob that can run an instance of lalapps_coherent_inspiral. N)rŠr Ú_CohInspBankNode__bankÚ_CohInspBankNode__ifos)rrrrr r œs zCohInspBankNode.__init__cCs | d|¡| |¡||_dS)Nz bank-file)r¢rºr_)rr¶rrr r»¤s  zCohInspBankNode.set_bankcCs|jS)N)r_)rrrr r¼©szCohInspBankNode.get_bankcCs| d|¡||_dS)Nrü)r¢r`)rrürrr rQ¬s zCohInspBankNode.set_ifoscCs|jS)N)r`)rrrr rý°szCohInspBankNode.get_ifoscCs| d|¡||_dS)z0 Set number of time slides to undertake z num-slidesN)r¢Z_CohInspBankNode__num_slides)rrþrrr rÿ³s zCohInspBankNode.set_num_slidescCs‚| ¡stdƒ‚| ¡d}| ¡r4|d| ¡7}|dt| ¡ƒdt| ¡| ¡ƒd}| ¡rt|d7}| |¡|S) zA Returns the file name of output from the coherent bank. zIfos have not been setz -COHINSPBANKr•r”z.xmlz.gzzlogs/z-$(cluster)-$(process).outz-$(cluster)-$(process).err) rýrr›rœr–r—r“ržr$r)r%)rrårŸrrr r ºs 0 zCohInspBankNode.get_outputN) r r r r2r r»r¼rQrýrÿr rrrr r^˜sr^c@s8eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd S) ÚChiaNodezR A ChiaNode runs an instance of the coherent_inspiral code in a Condor DAG. cCst ||¡dS)zU job = A CondorDAGJob that can run an instance of lalapps_coherent_inspiral. N)rŠr )rrrrr r ÛszChiaNode.__init__cCs| d|¡| |¡dS)Nz bank-file)r¢rº)rr¶rrr r»ás zChiaNode.set_bankcCs ||_dS)zx Set the ifo tag that is passed to the analysis code. @param ifo_tag: a string to identify one or more IFOs N)Ú_ChiaNode__ifo_tag)rr@rrr rAåszChiaNode.set_ifo_tagcCs|jS)z$ Returns the IFO tag string )rb)rrrr ršìszChiaNode.get_ifo_tagcCs’| ¡r| ¡r| ¡s tdƒ‚| ¡d}| ¡rD|d| ¡7}|dt| ¡ƒdt| ¡| ¡ƒd}| ¡r„|d7}| |¡|S)zA Returns the file name of output from coherent inspiral. z.Start time, end time or ifos have not been setz-CHIAr•r”z.xmlz.gz)r–r—ršrr›rœr“rž)rrårŸrrr r òs 0 zChiaNode.get_outputN) r r r r2r r»rAršr rrrr raÖs rac@s eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Zd$d%„Zd&S)'Ú CohireNodezR A CohireNode runs an instance of the inspiral cohire code in a Condor DAG. cCs.t ||¡d|_d|_d|_d|_d|_dS)zJ job = A CondorDAGJob that can run an instance of lalapps_cohire. N)rŠr Ú_CohireNode__ifosÚ_CohireNode__ifo_tagÚ_CohireNode__num_slidesÚ_CohireNode__injection_fileÚ_CohireNode__output_tag)rrrrr r s  zCohireNode.__init__cCs ||_dS)z) Add the list of interferometers N)rd)rrürrr rQszCohireNode.set_ifoscCs|jS)z Returns the ifos )rd)rrrr rýszCohireNode.get_ifoscCs||_| d|¡dS)z' Add the number of time slides z num-slidesN)rfr¢)rrRrrr rS$szCohireNode.set_slidescCs|jS)z& Returns the number of slides )rf)rrrr rT+szCohireNode.get_slidescCs|r||_| d|¡dS)z! Sets the injection file zinjection-fileN)rgr¢)rrrrr r81szCohireNode.set_inj_filecCs|jS)z! Gets the injection file )rg)rrrr r99szCohireNode.get_inj_filecCs ||_dS)z Sets GPS start time N)Ú_CohireNode__start)rr;rrr r<?szCohireNode.set_startcCs|jS)z Gets GPS start time )ri)rrrr r–EszCohireNode.get_startcCs ||_dS)z Sets GPS end time N)Ú_CohireNode__end)rr>rrr r?KszCohireNode.set_endcCs|jS)z Gets GPS end time )rj)rrrr r—QszCohireNode.get_endcCs ||_dS)zx Set the ifo tag that is passed to the analysis code. @param ifo_tag: a string to identify one or more IFOs N)re)rr@rrr rAWszCohireNode.set_ifo_tagcCs|jS)z$ Returns the IFO tag string )re)rrrr rš^szCohireNode.get_ifo_tagcCs˜| ¡ ¡ ¡}| ¡r |d7}| ¡r^|d| ¡ d¡d d¡d d¡d7}|d 7}| ¡rv|d| ¡7}| ¡rŽ|d| ¡7}||_dS) Nrr•rrfrgrr”r¿rB) rr.r™rTr9rmršr›rh)rrtrrr rWds*zCohireNode.set_output_tagcCs|jS)N)rh)rrrr rXoszCohireNode.get_output_tagcCs˜| ¡stdƒ‚| ¡| ¡d| ¡}| ¡r<| ¡rL| ¡rT| ¡sTtdƒ‚| ¡rŒ| ¡| ¡}|dt| ¡ƒdt|ƒ7}|d7}|S)z) get the name of the output file zifos have not been setr”z,If one of start and end is set, both must bez.xml)rýrrWrXr–r—rœ)rrtrCrrr r rs zCohireNode.get_outputcCs | ¡r| ¡ dd¡SdSdS)z) get the name of the missed file rDrEN)r9r rF)rrrr rG‰szCohireNode.get_missedcCs`| ¡}|jd|dd|jd| dd¡dd| ¡r\| d| ¡¡|jd| ¡ddd S) z set the output options r¯T)rHrIrrJzinjection-filezmissed-injectionsN)r rprFr9rG)rr¯rrr r§’s zCohireNode.finalizeN)r r r r2r rQrýrSrTr8r9r<r–r?r—rAršrWrXr rGr§rrrr rc s&   rcc@seZdZdZdd„ZdS)ÚInspInjFindNodezN An InspInjFindNode runs an instance of the InspInjJob in a Condor DAG. cCst ||¡dS)zT @param job: A CondorDAGJob that can run an instance of ligolw_inspinjfind. N)rŠr )rrrrr r ¥szInspInjFindNode.__init__N)r r r r2r rrrr rk srkc@seZdZdZdd„ZdS)ÚPlotInspiralrangeJobzû A plotinspiralrange job. The static options are read from the section [plotinspiralrange] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. Zplotinspiralranger€N)r3r )rr'r)r(r*rrr r ¶szPlotInspiralrangeJob.__init__N)r r r r2r rrrr rl¯srlc@seZdZdZdd„ZdS)ÚPlotInspiralrangeNodezZ A PlotInspiralrangeNode runs an instance of the plotinspiral code in a Condor DAG. cCst ||¡dS)zM job = A CondorDAGJob that can run an instance of plotinspiralrange. N)r¨r )rrrrr r ÄszPlotInspiralrangeNode.__init__N)r r r r2r rrrr rm¿srmc@seZdZdZdd„ZdS)ÚPlotInspiralJobzñ A plotinspiral job. The static options are read from the section [plotinspiral] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. Z plotinspiralr€N)r3r )rr'r)r(r*rrr r ÓszPlotInspiralJob.__init__N)r r r r2r rrrr rnÌsrnc@seZdZdZdd„ZdS)ÚPlotInspiralNodezS A PlotInspiralNode runs an instance of the plotinspiral code in a Condor DAG. cCst ||¡dS)zH job = A CondorDAGJob that can run an instance of plotinspiral. N)r¨r )rrrrr r àszPlotInspiralNode.__init__N)r r r r2r rrrr roÜsroc@seZdZdZdd„ZdS)Ú PlotThincaJobzí A plotthinca job. The static options are read from the section [plotthinca] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs0d}dg}d}t |||||¡| dd¡dS)zF @param cp = ConfigParser object from which options are read. Z plotthincar€rLÚ2500N)r3r r)rr'r)r(r*rrr r ïs zPlotThincaJob.__init__N)r r r r2r rrrr rpèsrpc@seZdZdZdd„ZdS)ÚPlotThincaNodezO A PlotThincaNode runs an instance of the plotthinca code in a Condor DAG. cCst ||¡dS)zF job = A CondorDAGJob that can run an instance of plotthinca. N)r¨r )rrrrr r ýszPlotThincaNode.__init__N)r r r r2r rrrr rrùsrrc@seZdZdZdd„ZdS)Ú PlotCohsnrJobzí A plotthinca job. The static options are read from the section [plotthinca] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. Z plotcohsnrr€N)r3r )rr'r)r(r*rrr r szPlotCohsnrJob.__init__N)r r r r2r rrrr rs srsc@seZdZdZdd„ZdS)ÚPlotCohsnrNodezO A PlotThincaNode runs an instance of the plotthinca code in a Condor DAG. cCst ||¡dS)zF job = A CondorDAGJob that can run an instance of plotthinca. N)r¨r )rrrrr r  szPlotCohsnrNode.__init__N)r r r r2r rrrr rt srtc@seZdZdZdd„ZdS)ÚPlotNumtemplatesJobzù A plotnumtemplates job. The static options are read from the section [plotnumtemplates] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. Zplotnumtemplatesr€N)r3r )rr'r)r(r*rrr r * szPlotNumtemplatesJob.__init__N)r r r r2r rrrr ru# sruc@seZdZdZdd„ZdS)ÚPlotNumtemplatesNodezW A PlotNumtemplatesNode runs an instance of the plotinspiral code in a Condor DAG. cCst ||¡dS)zL job = A CondorDAGJob that can run an instance of plotnumtemplates. N)r¨r )rrrrr r 7 szPlotNumtemplatesNode.__init__N)r r r r2r rrrr rv3 srvc@seZdZdZdd„ZdS)ÚPlotEthincaJobzï A plotethinca job. The static options are read from the section [plotethinca] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs0d}dg}d}t |||||¡| dd¡dS)zF @param cp = ConfigParser object from which options are read. Z plotethincar€rLrqN)r3r r)rr'r)r(r*rrr r F s zPlotEthincaJob.__init__N)r r r r2r rrrr rw? srwc@seZdZdZdd„ZdS)ÚPlotEthincaNodezR A PlotEthincaNode runs an instance of the plotinspiral code in a Condor DAG. cCst ||¡dS)zG job = A CondorDAGJob that can run an instance of plotethinca. N)r¨r )rrrrr r T szPlotEthincaNode.__init__N)r r r r2r rrrr rxP srxc@seZdZdZdd„ZdS)ÚPlotInspmissedJobzõ A plotinspmissed job. The static options are read from the section [plotinspmissed] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. Zplotinspmissedr€N)r3r )rr'r)r(r*rrr r c szPlotInspmissedJob.__init__N)r r r r2r rrrr ry\ sryc@seZdZdZdd„ZdS)ÚPlotInspmissedNodezU A PlotInspmissedNode runs an instance of the plotinspiral code in a Condor DAG. cCst ||¡dS)zJ job = A CondorDAGJob that can run an instance of plotinspmissed. N)r¨r )rrrrr r p szPlotInspmissedNode.__init__N)r r r r2r rrrr rzl srzc@seZdZdZdd„ZdS)ÚPlotEffdistcutJobzõ A ploteffdistcut job. The static options are read from the section [ploteffdistcut] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs$d}dg}d}t |||||¡dS)zF @param cp = ConfigParser object from which options are read. Zploteffdistcutr€N)r3r )rr'r)r(r*rrr r  szPlotEffdistcutJob.__init__N)r r r r2r rrrr r{x sr{c@seZdZdZdd„ZdS)ÚPlotEffdistcutNodezY A PlotEffdistcutNode runs an instance of the ploteffdistcut code in a Condor DAG. cCst ||¡dS)zJ job = A CondorDAGJob that can run an instance of ploteffdistcut. N)r¨r )rrrrr r szPlotEffdistcutNode.__init__N)r r r r2r rrrr r|ˆ sr|c@seZdZdZdd„ZdS)ÚPlotInspinjJobzï A plotinspinj job. The static options are read from the section [plotinspinj] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs0d}dg}d}t |||||¡| dd¡dS)zF @param cp = ConfigParser object from which options are read. Z plotinspinjr€rLrqN)r3r r)rr'r)r(r*rrr r œ s zPlotInspinjJob.__init__N)r r r r2r rrrr r}• sr}c@seZdZdZdd„ZdS)ÚPlotInspinjNodezR A PlotInspinjNode runs an instance of the plotinspiral code in a Condor DAG. cCst ||¡dS)zG job = A CondorDAGJob that can run an instance of plotinspinj. N)r¨r )rrrrr r ª szPlotInspinjNode.__init__N)r r r r2r rrrr r~¦ sr~c@seZdZdZdd„ZdS)Ú PlotSnrchiJobzí A plotsnrchi job. The static options are read from the section [plotsnrchi] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs0d}dg}d}t |||||¡| dd¡dS)zF @param cp = ConfigParser object from which options are read. Z plotsnrchir€rLrqN)r3r r)rr'r)r(r*rrr r ¹ s zPlotSnrchiJob.__init__N)r r r r2r rrrr r² src@seZdZdZdd„ZdS)ÚPlotSnrchiNodezQ A PlotSnrchiNode runs an instance of the plotinspiral code in a Condor DAG. cCst ||¡dS)zF job = A CondorDAGJob that can run an instance of plotsnrchi. N)r¨r )rrrrr r Ç szPlotSnrchiNode.__init__N)r r r r2r rrrr r€à sr€c@seZdZdZdd„ZdS)ÚPlotGRBtimeslideStatsJobzÿ A plotgrbtimeslidestats job. The static options are read from the section [grbtimeslidestats] in the ini file. The stdout and stderr from the job are directed to the logs directory. The path to the executable is determined from the ini file. cCs0d}dg}d}t |||||¡| dd¡dS)zF @param cp = ConfigParser object from which options are read. Zpylal_grbtimeslide_statsZgrbtimeslidestatsr€r4r5N)rr r)rr'r)r(r*rrr r Ö s z!PlotGRBtimeslideStatsJob.__init__N)r r r r2r rrrr rÏ src@seZdZdZdd„ZdS)ÚPlotGRBtimeslideStatsNodezh A PlotGRBtimeslideStatsNode runs an instance of the pylal_grbtimeslide_stats code in a Condor DAG. cCst ||¡dS)zT job = A CondorDAGJob that can run an instance of pylal_grbtimeslide_stats. N)rŠr )rrrrr r ä sz"PlotGRBtimeslideStatsNode.__init__N)r r r r2r rrrr r‚à sr‚c@s eZdZdZdd„Zdd„ZdS)ÚMiniFollowupsJobzf A minifollowups job. Static options are read from the [minifollowups] section in the ini file. cCs2d}ddg}d}t |||||¡| dd¡dS)zE @param cp: ConfigParser object from which options are read. Z minifollowupsz omega-scansNrLrq)r3r r)rr'r)r(r*rrr r ñ s zMiniFollowupsJob.__init__cCs| dd¡dS)z. Turns on the --time-slides argument. z time-slidesr_N)rZ)rrrr Úset_time_slidesû sz MiniFollowupsJob.set_time_slidesN)r r r r2r r„rrrr rƒì s rƒc@s˜eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Zd$S)%ÚMiniFollowupsNodez A mininfollowups node. cCs@t ||¡d|_d|_d|_d|_d|_d|_d|_d|_ dS)z( @param job: a MiniFollowupsJob N) rŠr Ú_MiniFollowupsNode__cache_fileÚ _MiniFollowupsNode__cache_stringÚ_MiniFollowupsNode__prefixÚ_MiniFollowupsNode__suffixÚ_MiniFollowupsNode__input_xmlÚ%_MiniFollowupsNode__input_xml_summaryÚ%_MiniFollowupsNode__output_html_tableÚ_MiniFollowupsNode__table_name)rrrrr r  s zMiniFollowupsNode.__init__cCs| d|¡||_dS)z* Set the ihope cache file to use. z cache-fileN)rpr†)rZ cache_filerrr Úset_cache_file s z MiniFollowupsNode.set_cache_filecCs|jS)z, Returns the cache file that's set. )r†)rrrr Úget_cache_file sz MiniFollowupsNode.get_cache_filecCs| d|¡||_dS)z* Set the ihope cache file to use. z cache-stringN)rpr‡)rr/rrr r0! s z"MiniFollowupsNode.set_cache_stringcCs|jS)z, Returns the cache file that's set. )r‡)rrrr Úget_cache_string( sz"MiniFollowupsNode.get_cache_stringcCs| d|¡||_dS)z? Sets the prefix option, which is used for plot names. ÚprefixN)r¢rˆ)rr‘rrr Ú set_prefix. s zMiniFollowupsNode.set_prefixcCs|jS)z' Return the prefix that's set. )rˆ)rrrr Ú get_prefix5 szMiniFollowupsNode.get_prefixcCs| d|¡||_dS)z? Sets the suffix option, which is used for plot names. ÚsuffixN)r¢r‰)rr”rrr Ú set_suffix; s zMiniFollowupsNode.set_suffixcCs|jS)z' Return the suffix that's set. )r‰)rrrr Ú get_suffixB szMiniFollowupsNode.get_suffixcCs| d|¡||_dS)z Sets the input xml. z input-xmlN)r¢rŠ)rZ input_xmlrrr Ú set_input_xmlH s zMiniFollowupsNode.set_input_xmlcCs|jS)z* Return the input_xml that's set. )rŠ)rrrr Ú get_input_xmlO szMiniFollowupsNode.get_input_xmlcCs| d|¡||_dS)z Sets the input xml. zinput-xml-summaryN)r¢r‹)rZinput_xml_summaryrrr Úset_input_xml_summaryU s z'MiniFollowupsNode.set_input_xml_summarycCs|jS)z2 Return the input_xml_summary that's set. )r‹)rrrr Úget_input_xml_summary\ sz'MiniFollowupsNode.get_input_xml_summarycCs| d|¡||_dS)z Sets the input xml. zoutput-html-tableN)r¢rŒ)rZoutput_html_tablerrr Úset_output_html_tableb s z'MiniFollowupsNode.set_output_html_tablecCs|jS)z2 Return the output_html_table that's set. )rŒ)rrrr Úget_output_html_tablei sz'MiniFollowupsNode.get_output_html_tablecCs| d|¡||_dS)z' Sets the table-name argument. z table-nameN)r¢r)rZ table_namerrr Úset_table_nameo s z MiniFollowupsNode.set_table_namecCs|jS)z+ Return the table_name that's set. )r)rrrr Úget_table_namev sz MiniFollowupsNode.get_table_nameN)r r r r2r rŽrr0rr’r“r•r–r—r˜r™ršr›rœrržrrrr r… s$r…c@seZdZdZdd„ZdS)Ú DBSimplifyJobzd A DBSimplify job. The static options are read from the section [dbsimplify] in the ini file. cCs d}dg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. Z dbsimplifyN)rÚ SqliteJobr )rr'r)r(rrr r … szDBSimplifyJob.__init__N)r r r r2r rrrr rŸ€ srŸc@seZdZdZdd„ZdS)ÚDBSimplifyNodez A DBSimplify node. cCstj ||¡dS)z% @param job: a DBSimplifyJob N)rÚ SqliteNoder )rrrrr r ’ szDBSimplifyNode.__init__N)r r r r2r rrrr r¡Ž sr¡c@seZdZdZdd„ZdS)ÚComputeDurationsJobzq A ComputeDurations job. The static options are read from the section [compute_durations] in the ini file. cCs d}dg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. Zcompute_durationsN)rr r )rr'r)r(rrr r ž szComputeDurationsJob.__init__N)r r r r2r rrrr r£™ sr£c@seZdZdZdd„ZdS)ÚComputeDurationsNodez A ComputeDurations node. cCstj ||¡dS)z+ @param job: a ComputeDurationsJob N)rr¢r )rrrrr r « szComputeDurationsNode.__init__N)r r r r2r rrrr r¤§ sr¤c@seZdZdZdd„ZdS)Ú DBAddInjJobz` A DBAddInj job. The static options are read from the section [dbaddinj] in the ini file. cCs d}dg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. ZdbaddinjN)rr r )rr'r)r(rrr r · szDBAddInjJob.__init__N)r r r r2r rrrr r¥² sr¥c@s8eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd S) Ú DBAddInjNodez A DBAddInj node. cCstj ||¡d|_d|_dS)z$ @param job: a DBAddInj job N)rr¢r Ú_DBAddInjNode__injection_fileÚ_DBAddInjNode__inj_tag)rrrrr r Ä szDBAddInjNode.__init__cCs| d|¡||_dS)zX @param injection_file: Injection file for dbaddinj to add to the database. zinjection-fileN)rpr§)rZinjection_filerrr Úset_injection_fileÌ s zDBAddInjNode.set_injection_filecCs|jS)z/ Returns injection file for this node. )Z_injection_file)rrrr Úget_injection_fileÔ szDBAddInjNode.get_injection_filecCs| d|¡||_dS)zH @param inj_tag: Injection tag used to name the injection files zsim-tagN)r¢r¨)rZinj_tagrrr Ú set_inj_tagÚ s zDBAddInjNode.set_inj_tagcCs|jS)z. Returns injection_tag for this node. )r¨)rrrr Ú get_inj_tagá szDBAddInjNode.get_inj_tagN) r r r r2r r©rªr«r¬rrrr r¦À s r¦c@seZdZdZdd„ZdS)Ú RepopCoincJobzf A repop_coinc job. The static options are read from the section [repop_coinc] in the ini file. cCs d}dg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. Z repop_coincN)rr r )rr'r)r(rrr r ì szRepopCoincJob.__init__N)r r r r2r rrrr r­ç sr­c@seZdZdZdd„ZdS)ÚRepopCoincNodez A repop_coinc node. cCstj ||¡dS)z% @param job: a RepopCoincJob N)rr¢r )rrrrr r ù szRepopCoincNode.__init__N)r r r r2r rrrr r®õ sr®c@seZdZdZdd„ZdS)Ú DBInjFindJobzb A dbinjfind job. The static options are read from the section [dbinjfind] in the ini file. cCs d}dg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. Z dbinjfindN)rr r )rr'r)r(rrr r  szDBInjFindJob.__init__N)r r r r2r rrrr r¯ sr¯c@seZdZdZdd„ZdS)Ú DBInjFindNodez A dbinjfind node. cCstj ||¡dS)z$ @param job: a DBInjFindJob N)rr¢r )rrrrr r  szDBInjFindNode.__init__N)r r r r2r rrrr r° sr°c@seZdZdZdd„ZdS)ÚClusterCoincsJobzl A cluster coincs job. The static options are read from the section [cluster_coincs] in the ini file. cCs d}dg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. Zcluster_coincsN)rr r )rr'r)r(rrr r  szClusterCoincsJob.__init__N)r r r r2r rrrr r± sr±c@seZdZdZdd„ZdS)ÚClusterCoincsNodez A ClusterCoincs node. cCstj ||¡dS)z( @param job: a ClusterCoincsJob N)rr¢r )rrrrr r + szClusterCoincsNode.__init__N)r r r r2r rrrr r²' sr²c@seZdZdZdd„ZdS)ÚCFarJobzX A cfar job. The static options are read from the section [cfar] in the ini file. cCsd}tj ||||¡dS)z @param cp: ConfigParser object from which options are read. @param sections: list of sections for cp to read from ZcfarN)rr r )rr'r(r)rrr r 7 szCFarJob.__init__N)r r r r2r rrrr r³2 sr³c@seZdZdZdd„ZdS)ÚCFarNodez A CFar node. cCstj ||¡dS)z @param job: a CFarJob N)rr¢r )rrrrr r D szCFarNode.__init__N)r r r r2r rrrr r´@ sr´c@seZdZdZdd„ZdS)ÚLigolwCBCPrintJobzj A LigolwCBCPrintJob is a generic job class for ligolw_cbc_print* programs, e.g., ligolw_cbc_printlc. cCstj ||||¡dS)z¡ @param cp: ConfigParser object from which options are read. @param exec_name UNDOCUMENTED @param sections: list of sections for cp to read from N)rr r )rr'r)r(rrr r O szLigolwCBCPrintJob.__init__N)r r r r2r rrrr rµK srµc@sˆeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zd S)!ÚLigolwCBCPrintNodez¡ A LigolwCBCPrintJob is a generic node class for ligolw_cbc_print* programs, e.g., ligolw_cbc_printlc. This class offers options common to these programs. cCs<tj ||¡d|_d|_d|_d|_d|_d|_d|_ dS)z" @param job: a PrintLCJob N) rr¢r Ú#_LigolwCBCPrintNode__extract_to_xmlÚ(_LigolwCBCPrintNode__extract_to_databaseÚ#_LigolwCBCPrintNode__exclude_coincsÚ(_LigolwCBCPrintNode__include_only_coincsÚ_LigolwCBCPrintNode__sim_tagÚ"_LigolwCBCPrintNode__output_formatÚ_LigolwCBCPrintNode__columns)rrrrr r ] szLigolwCBCPrintNode.__init__cCs| d|¡||_dS)z) Sets the extract-to-xml option. zextract-to-xmlN)r¢r·)rZ xml_filenamerrr Úset_extract_to_xmlj s z%LigolwCBCPrintNode.set_extract_to_xmlcCs|jS)z5 Gets xml-filename if extract-to-xml is set. )r·)rrrr Úget_extract_to_xmlq sz%LigolwCBCPrintNode.get_extract_to_xmlcCs| d|¡||_dS)z. Sets the extract-to-database option. zextract-to-databaseN)r¢r¸)rZdatabase_filenamerrr Úset_extract_to_databasew s z*LigolwCBCPrintNode.set_extract_to_databasecCs|jS)z? Gets database-filename if extract-to-database is set. )r¸)rrrr Úget_extract_to_database~ sz*LigolwCBCPrintNode.get_extract_to_databasecCs| d|¡||_dS)z% Sets exclude-coincs option. zexclude-coincsN)r¢r¹)rZexclude_coincsrrr Úset_exclude_coincs„ s z%LigolwCBCPrintNode.set_exclude_coincscCs|jS)z% Gets exclude-coincs option. )r¹)rrrr Úget_exclude_coincs‹ sz%LigolwCBCPrintNode.get_exclude_coincscCs| d|¡||_dS)z* Sets include-only-coincs option. zinclude-only-coincsN)r¢rº)rZinclude_only_coincsrrr Úset_include_only_coincs‘ s z*LigolwCBCPrintNode.set_include_only_coincscCs|jS)z* Gets include-only-coincs option. )rº)rrrr Úget_include_only_coincs˜ sz*LigolwCBCPrintNode.get_include_only_coincscCs| d|¡||_dS)z$ Sets the --sim-tag option. zsim-tagN)r¢r»)rÚsim_tagrrr Ú set_sim_tagž s zLigolwCBCPrintNode.set_sim_tagcCs|jS)z Gets sim-tag option. )r»)rrrr Ú get_sim_tag¥ szLigolwCBCPrintNode.get_sim_tagcCs| d|¡||_dS)zk Sets the output-format option. (Note that the default for all ligolw_cbc_print* jobs is xml.) z output-formatN)r¢r¼)rZ output_formatrrr Úset_output_format« s z$LigolwCBCPrintNode.set_output_formatcCs|jS)z( Gets the output-format option. )r¼)rrrr Úget_output_format³ sz$LigolwCBCPrintNode.get_output_formatcCs| d|¡||_dS)z" Sets the columns option. ÚcolumnsN)r¢r½)rrËrrr Ú set_columns¹ s zLigolwCBCPrintNode.set_columnscCs|jS)z" Gets the columns option. )r½)rrrr Ú get_columnsÀ szLigolwCBCPrintNode.get_columnsN)r r r r2r r¾r¿rÀrÁrÂrÃrÄrÅrÇrÈrÉrÊrÌrÍrrrr r¶X s  r¶c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú PrintLCNodezR A special instance of LigolwCBCPrintNode that adds printlc-specific methods. cCst ||¡d|_dS)z) @param job: a LigolwCBCPrintJob N)r¶r Ú_PrintLCNode__datatype)rrrrr r Ë s zPrintLCNode.__init__cCs| d|¡||_dS)z Sets datatype option. ÚdatatypeN)r¢rÏ)rrÐrrr Ú set_datatypeÒ s zPrintLCNode.set_datatypecCs|jS)z Gets datatype. )rÏ)rrrr Ú get_datatypeÙ szPrintLCNode.get_datatypeN)r r r r2r rÑrÒrrrr rÎÇ srÎc@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú PrintSimsNodezT A special instance of LigolwCBCPrintNode that adds printsims-specific methods. cCs"t ||¡d|_d|_d|_dS)z) @param job: a LigolwCBCPrintJob N)r¶r Ú#_PrintSimsNode__comparison_datatypeZ _PrintSimsNode__simulation_tableZ_PrintSimsNode__recovery_table)rrrrr r ã s zPrintSimsNode.__init__cCs| d|¡||_dS)z* Sets comparison-datatype option. zcomparison-datatypeN)r¢rÔ)rrÐrrr Úset_comparison_datatypeì s z%PrintSimsNode.set_comparison_datatypecCs|jS)z# Gets comparison-datatype. )rÔ)rrrr Úget_comparison_datatypeó sz%PrintSimsNode.get_comparison_datatypeN)r r r r2r rÕrÖrrrr rÓß s rÓc@seZdZdZdd„ZdS)ÚPrintMissedNodezV A special instance of LigolwCBCPrintNode that adds printmissed-specific methods. cCst ||¡dS)z) @param job: a LigolwCBCPrintJob N)r¶r )rrrrr r þ szPrintMissedNode.__init__N)r r r r2r rrrr r×ú sr×c@s eZdZdZdd„Zdd„ZdS)Ú PlotSlidesJobzf A plotslides job. The static options are read from the sections [plot_input] and [plotslides]. cCs"d}ddg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. Z plotslidesÚ plot_inputN)rr r )rr'r)r(rrr r szPlotSlidesJob.__init__cCs| dd¡dS)zT Sets plot-playground-only option. This causes job to only plot playground. zplot-playground-onlyr_N)rZ)rrrr Úset_plot_playground_only sz&PlotSlidesJob.set_plot_playground_onlyN)r r r r2r rÚrrrr rØ srØc@seZdZdZdd„ZdS)ÚPlotSlidesNodez A PlotSlides node. cCstj ||¡dS)z% @param job: a PlotSlidesJob N)rr¢r )rrrrr r  szPlotSlidesNode.__init__N)r r r r2r rrrr rÛ srÛc@s eZdZdZdd„Zdd„ZdS)ÚPlotCumhistJobzh A plotcumhist job. The static options are read from the sections [plot_input] and [plotcumhist]. cCs"d}ddg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. Z plotcumhistrÙN)rr r )rr'r)r(rrr r ) szPlotCumhistJob.__init__cCs| dd¡dS)zT Sets plot-playground-only option. This causes job to only plot playground. zplot-playground-onlyr_N)rZ)rrrr rÚ1 sz'PlotCumhistJob.set_plot_playground_onlyN)r r r r2r rÚrrrr rÜ$ srÜc@seZdZdZdd„ZdS)ÚPlotCumhistNodez A PlotCumhist node. cCstj ||¡dS)z' @param job: a PlotCumhist Job N)rr¢r )rrrrr r < szPlotCumhistNode.__init__N)r r r r2r rrrr rÝ8 srÝc@seZdZdZdd„ZdS)Ú PlotIfarJobzN A plotifar job. The static options are read from the [plotifar] section. cCs"d}ddg}tj ||||¡dS)zE @param cp: ConfigParser object from which options are read. ZplotifarrÙN)rr r )rr'r)r(rrr r G szPlotIfarJob.__init__N)r r r r2r rrrr rÞC srÞc@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú PlotIfarNodez A PlotIfar node. cCstj ||¡d|_dS)z# @param job: a PlotIfarJob N)rr¢r Ú_PlotIfarNode__datatype)rrrrr r T szPlotIfarNode.__init__cCs| d|¡||_dS)z Sets datatype option. rÐN)r¢rà)rrÐrrr rÑ[ s zPlotIfarNode.set_datatypecCs|jS)z Gets datatype. )rà)rrrr rÒb szPlotIfarNode.get_datatypeN)r r r r2r rÑrÒrrrr rßP srßc@seZdZdZdd„ZdS)Ú PlotFMJobzJ A plotfm job. The static options are read from the [plotfm] seciont. cCs"d}ddg}tj ||||¡dS)zE @param cp: ConfigParser object from which objects are read. ZplotfmrÙN)rr r )rr'r)r(rrr r l szPlotFMJob.__init__N)r r r r2r rrrr ráh srác@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú PlotFMNodez A PlotFM node. cCstj ||¡d|_dS)z! @param job: a PlotFMJob N)rr¢r Ú_PlotFMNode__sim_tag)rrrrr r x szPlotFMNode.__init__cCs| d|¡||_dS)z$ Sets the --sim-tag option. zsim-tagN)r¢rã)rrÆrrr rÇ s zPlotFMNode.set_sim_tagcCs|jS)z Gets sim-tag option. )rã)rrrr rȆ szPlotFMNode.get_sim_tagN)r r r r2r rÇrÈrrrr rât srâcCsX| ¡}| ¡}| ¡|}| ¡|}||kr8||kpV||krH||kpV||koV||kS)a¿ Test whether the two intervals could possibly overlap with one of them being slid by a maximum time of slide_sec. Perform three tests: 1) Does the start of interval 1 lie within interval 2's range (with the start decremented by slide_sec and the end incremented by slide_sec) 2) Does the end of interval 1 lie within interval 2's range (with the start decremented by slide_sec and the end incremented by slide_sec) 3) Does interval 1 completely cover (the extended) interval 2, ie is interval_1 start before (interval 2 start - slide_sec) AND interval 1 end after (interval 2 end + slide_sec) If any of the above conditions are satisfied then return True, else False. )r;r>)Z interval1Z interval2Z slide_secZstart1Zend1ÚleftÚrightrrr Ú overlap_test s   ræc@seZdZdZdd„ZdS)ÚSearchVolumeJobzÍ A search volume job. Computes the observed physical volume above a specified FAR; if FAR is not specified, computes the volume above the loudest event (open box) or FAR=1/livetime (closed box). cCs(d}tj ||dg|¡| dd¡dS)zE @param cp: ConfigParser object from which options are read. Z search_volumez search-volumer6z!KMP_LIBRARY=serial;MKL_SERIAL=yesN)rr r r)rr'r)rrr r ­ szSearchVolumeJob.__init__N)r r r r2r rrrr rç¦ srçc@s@eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dS)ÚSearchVolumeNodez A search volume node. cCstj ||¡dS)z N)rr¢r )rrrrr r ¹ szSearchVolumeNode.__init__cCs| |¡dS)N)Ú add_var_arg)rÚdbrrr Ú add_database¾ szSearchVolumeNode.add_databasecCs| d|¡dS)Nz output-cache)r¢)rrrrr Úset_output_cacheÁ sz!SearchVolumeNode.set_output_cachecCs| d|¡dS)Nzuser-tag)r¢)rÚtagrrr Ú set_user_tagÄ szSearchVolumeNode.set_user_tagcCs| d|¡dS)Nzveto-segments-name)r¢)rÚnamerrr r#Ç sz'SearchVolumeNode.set_veto_segments_namecCs| d¡dS)Nz --open-box)ré)rrrr Ú set_open_boxÊ szSearchVolumeNode.set_open_boxN) r r r r2r rërìrîr#rðrrrr rèµ srèc@seZdZdZdd„ZdS)ÚSearchUpperLimitJobz| A search upper limit job. Compute the search upper limit from the search volume output. Generates upper limit plots. cCs(d}tj ||dg|¡| dd¡dS)zx @param cp: ConfigParser object from which options are read. sections: list of sections for cp to read from Zsearch_upper_limitz upper-limitr6z!KMP_LIBRARY=serial;MKL_SERIAL=yesN)rr r r)rr'r)rrr r Ó szSearchUpperLimitJob.__init__N)r r r r2r rrrr rñÎ srñc@s0eZdZdZdd„Zdd„Zdd„Zdd „Zd S) ÚSearchUpperLimitNodez A search upper limit node. cCstj ||¡d|_dS)z+ @param job: a SearchUpperLimitJob FN)rr¢r Úopen_box)rrrrr r à szSearchUpperLimitNode.__init__cCs| |¡dS)N)ré)rrrrr Úadd_input_cacheç sz$SearchUpperLimitNode.add_input_cachecCs| d|¡dS)Nzuser-tag)r¢)rrírrr rîê sz!SearchUpperLimitNode.set_user_tagcCs|jsd|_| d¡dS)z Set the open box flag. Tz --open-boxN)róré)rrrr rðí sz!SearchUpperLimitNode.set_open_boxN)r r r r2r rôrîrðrrrr ròÜ s ròc@seZdZdZdd„ZdS)ÚMVSCDagGenerationJobzP a job that generates the mvsc_dag, which will be run as an external subdag cCsxd}d}d}| d|¡}tj |||¡tj ||¡| dd¡| d|d¡| d|d ¡| |d ¡d S) zE @param cp: ConfigParser object from which options are read. Zmvsc_dagr:z [mvsc_dag]rr4r5zlogs/z-$(cluster)-$(process).outz-$(cluster)-$(process).errz.subN) rrrr rrr$r%r&)rr'r)rr(r+rrr r ù s  zMVSCDagGenerationJob.__init__N)r r r r2r rrrr rõõ srõc@s(eZdZdZdd„Zdd„Zdd„ZdS) ÚMVSCDagGenerationNodezœ the node that runs the mvsc dag generation script for a given configuration generally the different nodes will be for different categories of vetoes cCst ||¡dS)N)rŠr )rrrrr r szMVSCDagGenerationNode.__init__cCs| |¡dS)N)ré)rZdatabaserrr Ú set_database sz"MVSCDagGenerationNode.set_databasecCs| d|¡dS)Nzuser-tag)r¢)rrírrr rî sz"MVSCDagGenerationNode.set_user_tagN)r r r r2r r÷rîrrrr rö sröc@seZdZdZdd„ZdS)ÚExtendedCoincJobzA job to calculate the extende background for zero far events cCs.d}g}d}t |||||¡| dd¡dS)zµ cp = ConfigParser object from which options are read. sections = sections of the ConfigParser that get added to the opts exec_name = exec_name name in ConfigParser Zextended_backgroundr€r4r5N)rr r)rr'r)r(r*rrr r  s zExtendedCoincJob.__init__N)r r r r2r rrrr rø srøc@sXeZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dS)ÚExtendedCoincNodezD Node to calculate the extended background for a zero far event cCst ||¡dS)N)rŠr )rrrrr r ) szExtendedCoincNode.__init__cCs| d|¡dS)Nzcoinc-threshold)r¢)rZcoinc_thresholdrrr Úset_coinc_threshold, sz%ExtendedCoincNode.set_coinc_thresholdcCs| d|¡dS)Nzihope-base-dir)r¢)rÚbase_dirrrr Úset_ihope_base_dir/ sz$ExtendedCoincNode.set_ihope_base_dircCs| d|¡dS)Nz param-ranges)r¢)rZ param_rangesrrr Úset_param_ranges2 sz"ExtendedCoincNode.set_param_rangescCs| d|¡dS)Nze-thinca-parameter)r¢)rZethincarrr Ú set_ethinca5 szExtendedCoincNode.set_ethincacCs| d|¡dS)Nz slide-step)r¢)rZ slide_steprrr Úset_slide_step8 sz ExtendedCoincNode.set_slide_stepcCs| d|¡dS)Nz veto-window)r¢)rZ veto_windowrrr Úset_veto_window; sz!ExtendedCoincNode.set_veto_windowcCs| d|¡dS)Nz new-snr-cut)r¢)rZ new_snr_cutrrr Úset_new_snr_cut> sz!ExtendedCoincNode.set_new_snr_cutcCs| d|¡dS)Nzloudest-event-glob)r¢)rZ event_globrrr Úset_loudest_event_globA sz(ExtendedCoincNode.set_loudest_event_globN) r r r r2r rúrürýrþrÿrrrrrrr rù% srù)r)ƒr2Ú __future__rÚ __author__Ú__date__Ú __version__rrir"rkrTrVZgluerrÚ Exceptionrrrrr3r7r=rGrHrIrJr^r`rbrcrdrurrr‚rƒr„r…r†r‡rˆr‰rŒr‹rŠr¨r©r²r´rµr·rÅrÊrÐrÔr×rÞrèrr)r4rKrYr[r^rarcrkrlrmrnrorprrrsrtrurvrwrxryrzr{r|r}r~rr€rr‚rƒr…r rŸr¢r¡r£r¤r¥r¦r­r®r¯r°r±r²r³r´rµr¶rÎrÓr×rØrÛrÜrÝrÞrßrárârærçrèrñròrõrörørùrrrr Úsò    F 9-8} 6, ,3)]u3}R>3           ~  '     o