document.py 文件源码

def on_delete(self, req, resp, doc_index):
        """
        Enqueueing write request as jobs into document_delete queue
        and processing them in the background with workers.
        """
        q = Queue('document_delete', connection=self.db.connection())
        job = q.enqueue_call(
            func=delDocument, args=(doc_index,), result_ttl=5000
        )
        LOG.info('DELETE request ' + str(job.get_id()))