def init_spider_job(self, spider_name):
        if spider_name in self.running_spider_dict:
            raise RunningJobException()
        spider = self.spider_manager.create(spider_name, settings=self.settings)
        crawl_engine = engine.EngineServer(spider, self.cluster_manager, self.scheduler)
        self.running_spider_dict[spider_name] = crawl_engine
dataset/ETHPy150Open wcong/ants/ants/crawl/crawl.py/CrawlServer.init_spider_job/original