sourcedb

*Master Side of the recipe *

class lofarpipe.recipes.master.setupsourcedb.setupsourcedb

Create a distributed Sky Model database (SourceDB) for a distributed Measurement Set (MS).

1. Load input and output mapfiles. Validate
2. Check if input skymodel file exists. If not, make filename empty.
3. Call node side of recipe
4. Validate performance and create output

Command line arguments

1. A mapfile describing the input data to be processed.
2. A mapfile with target location <if provided it will be validated against The input data>

Recipe inputs

Parameters:

• executable – (ExecField) Full path to makesourcedb executable (ExecField)
• mapfile – (StringField) Full path of mapfile to produce; it will contain a list of the generated sky-model files (StringField)
• nproc – (IntField) Maximum number of simultaneous processes per compute node (IntField)
• skymodel – (FileField) Input sky catalogue (FileField)
• suffix – (StringField) Suffix of the table name of the sky model (StringField)
• type – (StringField) Output type (casa or blob) (StringField)
• working_directory – (StringField) Working directory used on output nodes. Results will be written here. (StringField)

Recipe outputs (job.results[parameter])

Parameters:mapfile – (FileField) mapfile with created sourcedbpaths (FileField)

*Node Side of the recipe *

class lofarpipe.recipes.nodes.setupsourcedb.setupsourcedb(job_id, host, port)

Create the sourcedb at the supplied location

1. Create output directory if it does not yet exist.
2. Create sourcedb
3. validate performance, cleanup

run(executable, catalogue, skydb, dbtype)

Contains all functionality