diff --git a/django_celery_beat/schedulers.py b/django_celery_beat/schedulers.py index 2c1b5773..628a4ae2 100644 --- a/django_celery_beat/schedulers.py +++ b/django_celery_beat/schedulers.py @@ -76,6 +76,8 @@ def __init__(self, model, app=None): if getattr(model, 'expires_', None): self.options['expires'] = getattr(model, 'expires_') + if model.expire_seconds: + self.options['expire_seconds'] = model.expire_seconds self.options['headers'] = loads(model.headers or '{}') self.options['periodic_task_name'] = model.name