In [1]:

    

import pipeline as pl
pipeline = pl.get_pipeline('test_pipeline')


    

In [2]:

    

pipeline.add_command('cat <StepFile>', file_list=['hi.txt', 'bye.txt'])


    

In [3]:

    

pipeline['cat'].run_parallel()


    

In [4]:

    

print(pipeline)


    

    




Pipeline:
Step   Name   Status
0      cat    Done

In [5]:

    

print(pipeline['cat'])


    

    




Step:      cat
Command:   cat <StepFile>, Args: None
State:     COMPLETE
File list: ['hi.txt', 'bye.txt']
Ran on:    Tue Jan 26 15:57:28 2016
Runtime:   0:00:00.015530
Output:    False
STDERR:    False

In [6]:

    

print(pipeline['cat'].get_steps())


    

    





Step:      hi.txt
Command:   cat hi.txt, Args: None
State:     COMPLETE
Exit code: 0
Ran on:    Tue Jan 26 15:57:28 2016
Runtime:   0:00:00.005666
Output:    True
STDERR:    False

Output:
hello

Step:      bye.txt
Command:   cat bye.txt, Args: None
State:     COMPLETE
Exit code: 0
Ran on:    Tue Jan 26 15:57:28 2016
Runtime:   0:00:00.005781
Output:    True
STDERR:    False

Output:
Goodbye