schedulers.py 文件源码

def _unpack_entry_fields(cls, schedule, args=None, kwargs=None,
                             relative=None, options=None, **entry):
        def _unpack_entry_options(queue=None, exchange=None, routing_key=None,
                                  **kwargs):
            return {
                'queue': queue,
                'exchange': exchange,
                'routing_key': routing_key
            }

        model_schedule, model_field = cls.to_model_schedule(schedule)
        entry.update(
            {
                model_field: model_schedule
            },
            args=args or [],
            kwargs=kwargs or {},
            **_unpack_entry_options(**options or {})
        )
        return entry