Fixed stale time limit settings

druids · Nov 22, 2022 · 7041a25 · 7041a25
1 parent 87e1cac
commit 7041a25
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/django_celery_extensions/task.py b/django_celery_extensions/task.py
@@ -397,8 +397,8 @@ def _get_stale_time_limit(self, expires, time_limit, stale_time_limit, trigger_t
 
         if stale_time_limit is not None:
             return stale_time_limit
-        elif stale_time_limit is not None:
-            return stale_time_limit
+        elif self.stale_time_limit is not None:
+            return self.stale_time_limit
         elif settings.DEFAULT_TASK_STALE_TIME_LIMIT is not None:
             return settings.DEFAULT_TASK_STALE_TIME_LIMIT
         elif time_limit is not None and max_queue_waiting_time: