def _StartAnalysisProcesses(self, storage_writer, analysis_plugins):
    logger.info('Starting analysis plugins.')
    for analysis_plugin in analysis_plugins.values():
      self._analysis_plugins[analysis_plugin.NAME] = analysis_plugin
      process = self._StartWorkerProcess(analysis_plugin.NAME, storage_writer)
      if not process:
        logger.error('Unable to create analysis process: {0:s}'.format(
            analysis_plugin.NAME))
    logger.info('Analysis plugins running')