'Augment the pipeline config with an additional element.'

def _augment_pipeline_cfg(self):

    self.pipeline_cfg['sources'].append({'name': 'second_source', 'events': ['b'], 'sinks': ['second_sink']})
    self.pipeline_cfg['sinks'].append({'name': 'second_sink', 'publishers': ['new://']})
