From 9c2bb7ba25b7ac642e44635ec34a02a4a358e3ce Mon Sep 17 00:00:00 2001 From: Babak Ghadiri Date: Mon, 11 Jul 2022 15:31:19 +0430 Subject: [PATCH 1/2] Support expire_seconds --- django_celery_beat/schedulers.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/django_celery_beat/schedulers.py b/django_celery_beat/schedulers.py index 176b95ec..ba19c021 100644 --- a/django_celery_beat/schedulers.py +++ b/django_celery_beat/schedulers.py @@ -83,6 +83,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'] = self.expire_seconds self.options['headers'] = loads(model.headers or '{}') self.options['periodic_task_name'] = model.name From abd7c95766c810a9f9d9394f67ada81f40da931f Mon Sep 17 00:00:00 2001 From: Babak Ghadiri Date: Mon, 11 Jul 2022 15:33:45 +0430 Subject: [PATCH 2/2] Fix setting expire_seconds --- django_celery_beat/schedulers.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/django_celery_beat/schedulers.py b/django_celery_beat/schedulers.py index ba19c021..5178e582 100644 --- a/django_celery_beat/schedulers.py +++ b/django_celery_beat/schedulers.py @@ -84,7 +84,7 @@ 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'] = self.expire_seconds + self.options['expire_seconds'] = model.expire_seconds self.options['headers'] = loads(model.headers or '{}') self.options['periodic_task_name'] = model.name