<filename>disco/pipelines/factory.py
from jade.utils.utils import load_data
from disco.pipelines.base import PipelineTemplate
from disco.pipelines.creator import (
    SnapshotPipelineCreator,
    TimeSeriesPipelineCreator,
    UpgradePipelineCreator
)
from disco.enums import SimulationType
from disco.sources.factory import make_source_model


PIPELINE_CREATOR_MAPPING = {
    SimulationType.SNAPSHOT: SnapshotPipelineCreator,
    SimulationType.TIME_SERIES: TimeSeriesPipelineCreator,
    SimulationType.UPGRADE: UpgradePipelineCreator
}


class PipelineCreatorFactory:
    """Factory class for getting pipeline creator"""
    
    @classmethod
    def create(cls, template_file):
        """Create pipeline creator"""
        template = PipelineTemplate(template_file)
        simulation_type = SimulationType(template.data["simulation_type"])
        pipeline_creator_class = PIPELINE_CREATOR_MAPPING[simulation_type]
        pipeline_creator = pipeline_creator_class(template_file)
        return pipeline_creator

<filename>disco/pipelines/factory.py
from jade.utils.utils import load_data
from disco.pipelines.base import PipelineTemplate
from disco.pipelines.creator import (
    SnapshotPipelineCreator,
    TimeSeriesPipelineCreator,
    UpgradePipelineCreator
)
from disco.enums import SimulationType
from disco.sources.factory import make_source_model


PIPELINE_CREATOR_MAPPING = {
    SimulationType.SNAPSHOT: SnapshotPipelineCreator,
    SimulationType.TIME_SERIES: TimeSeriesPipelineCreator,
    SimulationType.UPGRADE: UpgradePipelineCreator
}


class PipelineCreatorFactory:
    """Factory class for getting pipeline creator"""
    
    @classmethod
    def create(cls, template_file):
        """Create pipeline creator"""
        template = PipelineTemplate(template_file)
        simulation_type = SimulationType(template.data["simulation_type"])
        pipeline_creator_class = PIPELINE_CREATOR_MAPPING[simulation_type]
        pipeline_creator = pipeline_creator_class(template_file)
        return pipeline_creator

Factory class for getting pipeline creator Create pipeline creator