celery_deadline.py 文件源码

def Producer(self, *args, **kwargs):
        kwargs['deadline_pulse_url'] = self.app.conf.get('deadline_pulse_url')
        print("deadline_pulse_url %s" % kwargs['deadline_pulse_url'])
        kwargs['deadline_mongo_url'] = self.mongo_url
        return DeadlineProducer(*args, **kwargs)