public class PipelineRegisterer {
private final PluginConfigurer configurer;
public PipelineRegisterer(PluginConfigurer configurer) {
this.configurer = configurer;
}
<BUG>public Pipeline registerPlugins(ETLConfig config) {
ETLStage sourceConfig = config.getSource();</BUG>
ETLStage sinkConfig = config.getSink();
List<ETLStage> transformConfigs = config.getTransforms();
String sourcePluginId = PluginID.from(Constants.Source.PLUGINTYPE, sourceConfig.getName(), 1).getID();

public class PipelineRegisterer {
private final PluginConfigurer configurer;
public PipelineRegisterer(PluginConfigurer configurer) {
this.configurer = configurer;
}
public Pipeline registerPlugins(ETLConfig config, Class errorDatasetType, DatasetProperties datasetProperties) {
ETLStage sourceConfig = config.getSource();
ETLStage sinkConfig = config.getSink();
List<ETLStage> transformConfigs = config.getTransforms();
String sourcePluginId = PluginID.from(Constants.Source.PLUGINTYPE, sourceConfig.getName(), 1).getID();
