Replace celery @task by @shared_task (removed in celery 5.2)

debexpo/importer/tasks.py

@@ -26,7 +26,7 @@
 #   FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
 #   OTHER DEALINGS IN THE SOFTWARE.
 
-from celery.decorators import task
+from celery import shared_task
 
 from django.conf import settings
 
@@ -34,7 +34,7 @@ from debexpo.importer.models import Importer
 from debexpo.tools.cache import enforce_unique_instance
 
 
-@task
+@shared_task
 def importer():
     with enforce_unique_instance('importer'):
         importctl = Importer(settings.UPLOAD_SPOOL)

debexpo/packages/tasks.py

@@ -27,7 +27,7 @@
 #   FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
 #   OTHER DEALINGS IN THE SOFTWARE.
 
-from celery.decorators import task
+from celery import shared_task
 from datetime import timedelta, datetime, timezone
 from logging import getLogger
 from debian.deb822 import Changes
@@ -97,7 +97,7 @@ def remove_uploads(uploads):
     return removals
 
 
-@task
+@shared_task
 def remove_old_uploads():
     expiration_date = datetime.now(timezone.utc) - \
         timedelta(weeks=settings.MAX_AGE_UPLOAD_WEEKS)
@@ -128,7 +128,7 @@ def notify_uploaders(removals, reason):
                    reason=reason)
 
 
-@task
+@shared_task
 def remove_uploaded_packages(client=None):
     uploads_to_archive = set()
     uploads_to_new = set()