feat!: django 5.2 support

Author: awais786

CHANGELOG.rst

@@ -14,6 +14,9 @@ Change Log
 Unreleased
 ~~~~~~~~~~
 
+[1.4.0] - 2024-03-31
+~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+* Added django5.2 support. Adding new migration with index_together change.
 * Dropped Python 3.8 support
 
 [1.3.0] - 2024-03-31

celery_utils/__init__.py

@@ -2,4 +2,4 @@
 Code to support working with celery.
 """
 
-__version__ = '1.3.0'
+__version__ = '1.4.0'

celery_utils/logged_task.py

@@ -30,7 +30,7 @@ def apply_async(self, args=None, kwargs=None, **options):  # pylint: disable=arg
         ))
         return result
 
-    def on_retry(self, exc, task_id, args, kwargs, einfo):
+    def on_retry(self, exc, task_id, args, kwargs, einfo):  # pylint: disable=too-many-positional-arguments
         """
         Capture the exception that caused the task to be retried, if any.
         """
@@ -41,7 +41,7 @@ def on_retry(self, exc, task_id, args, kwargs, einfo):
             )
         )
 
-    def on_failure(self, exc, task_id, args, kwargs, einfo):
+    def on_failure(self, exc, task_id, args, kwargs, einfo):  # pylint: disable=too-many-positional-arguments
         """
         Capture the exception that caused the task to fail, if any.
         """

celery_utils/migrations/0003_rename_failedtask_task_name_exc_idx_failedtask_task_exc.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.11 on 2025-04-09 02:33
+
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('celery_utils', '0002_chordable_django_backend'),
+    ]
+
+    operations = [
+        migrations.RenameIndex(
+            model_name='failedtask',
+            new_name='idx_failedtask_task_exc',
+            old_fields=('task_name', 'exc'),
+        ),
+    ]

celery_utils/models.py

@@ -39,8 +39,8 @@ class Meta:
         To specify any metadata for FailedTask model.
         """
 
-        index_together = [
-            ('task_name', 'exc'),
+        indexes = [
+            models.Index(fields=['task_name', 'exc'], name='idx_failedtask_task_exc')
         ]
 
     def reapply(self):

celery_utils/persist_on_failure.py

@@ -18,7 +18,7 @@ class PersistOnFailureTask(Task):
     abstract = True
     typing = False
 
-    def on_failure(self, exc, task_id, args, kwargs, einfo):
+    def on_failure(self, exc, task_id, args, kwargs, einfo):  # pylint: disable=too-many-positional-arguments
         """
         If the task fails, persist a record of the task.
         """

setup.py

@@ -154,5 +154,7 @@ def is_requirement(line):
         'Programming Language :: Python :: 3',
         'Programming Language :: Python :: 3.11',
         'Programming Language :: Python :: 3.12',
+        'Framework :: Django :: 4.2',
+        'Framework :: Django :: 5.2',
     ],
 )