forked from wtsi-npg/p4
-
Notifications
You must be signed in to change notification settings - Fork 0
jidur/p4
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
25/4/14 (kl2) The viv.pl script executes a set of commands and manages the flow of data between them, currently by using a combination of files and named pipes (FIFOs). It is configured with a JSON file which describes a connected directed graph. The format of the config is described below and there are some sample config files in the examples directory for reference. Usage ===== viv.pl [-s] [-x] [-v <verbose_level>] [-o <logname>] <config.json> Flags: -s : strict; that is, fail if any of the executed commands exit with a non-zero status -x : execute; by default, the script will just parse the config file and report in the log what processes it would have created -v <verbosity_level> : specify how chatty the log messages should be. Currently, verbosity levels range from 0 to 3 -o <logname> : specify the log file name (default stdout) config.json : a JSON formatted file specifying a directed graph. The config is a hash array with two keys: 1) "nodes" - a list of nodes, which are hash arrays with keys: "id" - a unique identifier for the node, used in the edges to specify the "from" and "to" nodes "type" - possible values INFILE, OUTFILE, RAFILE and EXEC (see below for more detail) "name" - for a file node {INFILE, OUTFILE, RAFILE}, this specifies the name of the file. "cmd" - for an EXEC node, specifies the command to be executed. Port names can specified (currently these are arbitrary embedded strings which are replaced by FIFO names generated at execution time) 2) "edges" - a list of edges, which are hash arrays with keys: "id" - a unique identifier for the edge "from" - contains an id value for a node, followed by an optional ':' and a port name. When a port name is specified, occurrences of that port name in the EXEC node are replaced by the names of FIFOs generated by the script to direct I/O between the nodes "to" - contains an id value for a node, followed by an optional ':' and a port name. When a port name is specified, the same substitution process described above (under "to") is applied. Node types, attributes and behaviour ==================================== INFILE specifies a file on the file system for reading OUTFILE specifies a file on the file system for writing RAFILE specifies an intermediate file on the file system for reading and writing. Used to move data between EXEC nodes when it is decided not to use the default pipe behaviour. When this node type is used, downstream nodes will not be launched until execution of any directly upstream nodes has completed. This node can have a "subtype" attribute with value "DUMMY" to indicate that that viv script should not take responsibility for creating the file (via output redirection), it should just coordinate execution of the connected EXEC nodes. EXEC specifies a command to be executed. The actual command appears in the "cmd" attribute". Direct data transfer between EXEC nodes is done via named pipes (fifos), which are automatically created by the script. Input/output defaults to stdin/stdout respectively, unless the "to" or "from" attributes include a port specification. TODO ==== 1. Improve logging. There is currently only one log file, it might be useful to have separate execution logs for each EXEC node, or at least clearer separation and labelling in the master log file. 2. Validate the graph. Currently there is little checking to see if the graph specification makes sense. For example, if a node tries to use an input or output port in another node, no checks are done to see if such a port actually exists. No checks are done to ensure that nodes specified in edges actually exist. The id for a node should also be unique for a given graph, but this is not checked. There is also no check to make sure that the graph is connected, so it is easy to specify orphan EXEC nodes which wait forever for input. So for the time being, be careful.
About
Process and Pipe Pipeline Panacea
Resources
Stars
Watchers
Forks
Packages 0
No packages published
Languages
- Perl 91.5%
- JavaScript 5.5%
- HTML 2.4%
- Other 0.6%