pipeline.recipereducer

recipereducer is a utility to reduce data using a standard pipeline procedure. It parses a XML reduction recipe, converts it to pipeline tasks, and executes the tasks for the given data. It was written to give pipeline developers without access to PPRs and/or a PPR generator a way to reduce data using the latest standard recipe.

Note: multiple input datasets can be specified. Doing so will reduce the data

as part of the same session.

Example #1: process uid123.tar.gz using the standard recipe.

import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’])

Example #2: process uid123.tar.gz using a named recipe.

import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’],

procedure=’procedure_hif.xml’)

Example #3: process uid123.tar.gz and uid124.tar.gz using the standard recipe.

import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’, ‘uid124.tar.gz’])

Example #4: process uid123.tar.gz, naming the context ‘testrun’, thus

directing all weblog output to a directory called ‘testrun’.

import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’], name=’testrun’)

Example #5: process uid123.tar.gz with a log level of TRACE

import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’], loglevel=’trace’)

Functions

reduce([vis, infiles, procedure, context, …])
string_to_val(s)	Convert a string to a Python data type.

Classes

TaskArgs(vis, infiles, session)