old_contents: from plumbium import call, record, pipeline
  
  
  @record()
  def pipeline_stage_1():
      call(['/Users/jstutters/proj/Plumbium/example/example_script.sh'])
  
  
  @record()
  def pipeline_stage_2():
      call(['/Users/jstutters/proj/Plumbium/example/example_script2.sh'])
  
  
  def my_pipeline():
      pipeline_stage_1()
      pipeline_stage_2()
  
  
  def example_pipeline():
      pipeline.run('example', my_pipeline)
  
  
  if __name__ == '__main__':
      example_pipeline()
  
new_contents: from plumbium import call, record, pipeline
  from plumbium.artefacts import TextFile
  import os
  
  
  @record()
  def pipeline_stage_1(f):
      print 'calling cat on', f.filename, 'in', os.getcwd()
      call(['/bin/cat', f.filename])
  
  
  @record()
  def pipeline_stage_2(f):
      call(['/bin/cat', f.filename])
  
  
  def my_pipeline(file1, file2):
      pipeline_stage_1(file1)
      pipeline_stage_2(file2)
  
  
  def example_pipeline():
      pipeline.run(
          'example',
          my_pipeline,
          '/Users/jstutters/proj/Plumbium/example',
          TextFile('m0/data.txt'), TextFile('m12/data.txt')
      )
  
  
  if __name__ == '__main__':
      example_pipeline()
  
subject: Use cat for examples