

def process_item(self, item, spider):
    if isinstance(item, dbitem.DbItem):
        self.db_pool.runQuery(item['query']).addCallback(item['callback'])
    return item

dataset/ETHPy150Open wcong/ants/antsext/db-pipe-line.py CrawlPipeline.process_item/original