bilby_pipe.job_creation.nodes

Submodules

Classes

AnalysisNode

Base Node object, handles creation of arguments, executables, etc

FinalResultNode

Base Node object, handles creation of arguments, executables, etc

GenerationNode

Base Node object, handles creation of arguments, executables, etc

MergeNode

Base Node object, handles creation of arguments, executables, etc

PESummaryNode

Base Node object, handles creation of arguments, executables, etc

PlotNode

Base Node object, handles creation of arguments, executables, etc

PostProcessAllResultsNode

Base Node object, handles creation of arguments, executables, etc

PostProcessSingleResultsNode

Base Node object, handles creation of arguments, executables, etc

Package Contents

class bilby_pipe.job_creation.nodes.AnalysisNode(inputs, generation_node, detectors, sampler, parallel_idx, dag)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

run_node_on_osg = True
dag
generation_node
detectors
parallel_idx
request_cpus
base_job_name
label
property executable
property request_memory
property log_directory
property result_file
property slurm_walltime

Default wall-time for base-name

class bilby_pipe.job_creation.nodes.FinalResultNode(inputs, parent_node, dag)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

dag
request_cpus = 1
job_name
property executable
property request_memory
property log_directory
class bilby_pipe.job_creation.nodes.GenerationNode(inputs, trigger_time, idx, dag, parent=None)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

inputs
trigger_time
idx
dag
request_cpus = 1
property resolve_frame_files

Resolve frame files from frame_type_dict and data_dict. For each detector, if the frame filepath(s) is given return the filepath(s), otherwise use gwdatafind to resolve the frame files using the provided frame type.

static extract_paths_from_dict(input)[source]
property executable
property request_memory
property log_directory
property universe
property job_name
property label
property data_dump_file
_file_needs_authentication(fname)[source]

Check if a file needs authentication to be accessed, currently the only repositories that need authentication are ligo.osgstorage.org and *.storage.igwn.org.

Parameters:
fname: str

The file name to check

property igwn_scitoken_lines
class bilby_pipe.job_creation.nodes.MergeNode(inputs, parallel_node_list, detectors, dag)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

dag
job_name
label
request_cpus = 1
property executable
property request_memory
property log_directory
property result_file
class bilby_pipe.job_creation.nodes.PESummaryNode(inputs, merged_node_list, generation_node_list, dag)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

dag
job_name
request_cpus = 1
property executable
property request_memory
property log_directory
class bilby_pipe.job_creation.nodes.PlotNode(inputs, merged_node, dag)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

dag
job_name
label
request_cpus = 1
property executable
property request_memory
property log_directory
property universe
class bilby_pipe.job_creation.nodes.PostProcessAllResultsNode(inputs, merged_node_list, dag)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

dag
request_cpus = 1
job_name
property executable
property request_memory
property log_directory
class bilby_pipe.job_creation.nodes.PostProcessSingleResultsNode(inputs, merged_node, dag)[source]

Bases: bilby_pipe.job_creation.node.Node

Base Node object, handles creation of arguments, executables, etc

dag
request_cpus = 1
job_name
property executable
property request_memory
property log_directory