schedulers.py 文件源码

def __init__(self, model, app=None):
        super().__init__(
            name=model.name,
            task=model.task,
            last_run_at=model.meta.last_run_at,
            total_run_count=model.meta.total_run_count,
            schedule=model.schedule,
            args=model.args,
            kwargs=model.kwargs,
            options={
                'queue': model.queue,
                'exchange': model.exchange,
                'routing_key': model.routing_key,
                'expires': model.expires_at
            },

            app=app or celery_app._get_current_object()
        )

        self.model = model