bilby_pipe.job_creation.node

Classes

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

Functions

_log_output_error_submit_lines(logdir, prefix)

Returns the filepaths for condor log, output, and error options

Module Contents

class bilby_pipe.job_creation.node.Node(inputs, retry=None)

Bases: object

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

run_node_on_osg = False

inputs

_universe = 'vanilla'

request_disk

getenv = True

notification

retry

verbose = 0

condor_job_priority

disable_hdf5_locking

extra_lines

requirements

property universe

process_node()

_get_executable_path(exe_name)

setup_arguments(parallel_program=None, add_command_line_args=True, add_ini=True, add_unknown_args=True)

abstract property log_directory

create_pycondor_job()

add_accounting()

Add the accounting-group and accounting-group-user extra lines

static _checkpoint_submit_lines()

static _condor_file_transfer_lines(inputs, outputs)

static _relative_topdir(path, reference)

Returns the top-level directory name of a path relative to a reference

_osg_submit_options(executable, has_ligo_frames=False)

Returns the extra submit lines and requirements to enable running a job on the Open Science Grid

Returns:

lineslist

the list of extra submit lines to include

requirementsstr

the extra requirements line to include

property slurm_walltime

Default wall-time for base-name

bilby_pipe.job_creation.node._log_output_error_submit_lines(logdir, prefix)

Returns the filepaths for condor log, output, and error options

Parameters:

logdirstr

the target directory for the files

prefixstr

the prefix for the files

Returns:

log, output, errorlist of str

the list of three file paths to be passed to pycondor.Job

Examples

>>> Dag._log_output_error_submit_lines("test", "job")
['log = test/job.log',
 'output = test/job.out',
 'error = test/job.err']