runPipeline: Run a pipeline
In anhinton/conduit: A prototype glue system for OpenAPI

Description Usage Arguments Details Value See Also Examples

Executes a pipeline's components.

1	runPipeline(pipeline, targetDirectory = getwd())

`pipeline`	A `pipeline` object
`targetDirectory`	File path for pipeline output

This function creates a directory named for pipeline, in a directory called ‘pipelines’, in the targetDirectory (‘targetDirectory/pipelines/$NAME$’). If the directory ‘pipelines’ does not exist in targetDirectory it will be created. Working files and output from the pipeline's components will be stored in the named directory.

The function returns a pipelineResult list object, containing a list of output objects produced by the pipeline's components.

pipelineResult object

pipelineResult objects. More about pipeline objects, run single module objects with runModule.

simpleGraph <-
    loadPipeline(name = "simpleGraph",
                 ref = system.file("extdata", "simpleGraph",
                                   "pipeline.xml",
                                    package = "conduit"))

## run the pipeline
result1 <- runPipeline(simpleGraph, targetDirectory = tempdir())

## python language example
pythonExample <- loadPipeline("pythonExample",
                              system.file("extdata", "pythonExample",
                                          "pipeline.xml", package="conduit"))
result2 <- runPipeline(pythonExample, targetDirectory = tempdir())

## bash language example
bashExample <- loadPipeline("bashExample",
                             system.file("extdata", "bashExample",
                                         "pipeline.xml", package="conduit"))
result3 <- runPipeline(bashExample, targetDirectory = tempdir())

## A pipeline with a module run on a remote host
## Not run: 
  irisplots_host_pipeline <- loadPipeline(
      "irisplots_host_pipeline",
      system.file("extdata", "irisplots_host", "pipeline.xml",
      package = "conduit"))
  runPipeline(irisplots_host_pipeline, targetDirectory = tempdir())

## End(Not run)