def __init__()

in granule_ingester/granule_ingester/pipeline/Pipeline.py [0:0]

• 16 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self,
                 granule_loader: GranuleLoader,
                 slicer: TileSlicer,
                 data_store_factory,
                 metadata_store_factory,
                 tile_processors: List[TileProcessor],
                 max_concurrency: int,
                 log_level=logging.INFO):
        self._granule_loader = granule_loader
        self._tile_processors = tile_processors
        self._slicer = slicer
        self._data_store_factory = data_store_factory
        self._metadata_store_factory = metadata_store_factory
        self._max_concurrency = int(max_concurrency)
        self._level = log_level

        # Create a SyncManager so that we can to communicate exceptions from the
        # worker processes back to the main process.
        self._manager = Manager()