'Setup the appropriate form of pipeline config.'

def _setup_pipeline_cfg(self):

    source = {'name': 'test_source', 'events': ['a'], 'sinks': ['test_sink']}
    sink = {'name': 'test_sink', 'publishers': ['test://']}
    self.pipeline_cfg = {'sources': [source], 'sinks': [sink]}
