package
Version:
v0.8.5
Opens a new window with list of versions in this module.
Published: Jul 1, 2015
License: Apache-2.0
Opens a new window with license information.
Imports: 18
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
package pipeline implements a system for running data pipelines on top of
the filesystem
func RunPipelines(pipelineDir, inRepo, outRepo, commit, branch, shard string) error
RunPipelines lets you easily run the Pipelines in one line if you don't care about cancelling them.
func WaitPipeline(pipelineDir, pipeline, commit string) error
WaitPipeline waits for a pipeline to complete. If the pipeline fails
ErrFailed is returned.
func NewRunner(pipelineDir, inRepo, outPrefix, commit, branch, shard string) *Runner
Inputs returns all of the inputs for the pipelines.
Run runs all of the pipelines it finds in pipelineDir. Returns the
first error it encounters.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.