Remove migrated celery tasks

Author: jmsmkn

app/grandchallenge/core/tasks.py

@@ -3,7 +3,6 @@
 import boto3
 from django.conf import settings
 from django.contrib.sites.models import Site
-from django.db import transaction
 from django.db.models import Count
 from django.utils import timezone
 from django.utils.timezone import now
@@ -17,18 +16,10 @@
     PostProcessImageTask,
     RawImageUploadSession,
 )
-from grandchallenge.core.celery import acks_late_micro_short_task
 from grandchallenge.evaluation.models import Evaluation, Method
 from grandchallenge.workstations.models import Session
 
 
-@acks_late_micro_short_task(name=f"{__name__}.cleanup_celery_backend")
-@transaction.atomic
-def cleanup_celery_backend_celery():
-    # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
-    return cleanup_celery_backend()
-
-
 @lambda_task
 def cleanup_celery_backend():
     """Cleanup the Celery backend."""

app/grandchallenge/direct_messages/tasks.py

@@ -3,7 +3,6 @@
 from django.db.models import Count, F, Q
 from lambda_tasks.decorators import lambda_task
 
-from grandchallenge.core.celery import acks_late_micro_short_task
 from grandchallenge.profiles.models import NotificationEmailOptions
 
 
@@ -48,14 +47,6 @@ def get_new_senders(*, user):
     return sorted(list(new_senders), key=lambda s: s.pk)
 
 
-@acks_late_micro_short_task(
-    name=f"{__name__}.send_new_unread_direct_messages_emails"
-)
-def send_new_unread_direct_messages_emails_celery():
-    # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
-    return send_new_unread_direct_messages_emails()
-
-
 @lambda_task
 def send_new_unread_direct_messages_emails():
     site = Site.objects.get_current()

app/grandchallenge/discussion_forums/tasks.py

@@ -1,30 +1,16 @@
 from uuid import UUID
 
 from actstream.actions import follow
-from celery.utils.log import get_task_logger
 from django.apps import apps
-from django.db import transaction
 from lambda_tasks.decorators import lambda_task
+from lambda_tasks.logging import task_logger
 
-from grandchallenge.core.celery import acks_late_micro_short_task
 from grandchallenge.core.exceptions import LockNotAcquiredException
 from grandchallenge.notifications.models import (
     Notification,
     NotificationTypeChoices,
 )
 
-logger = get_task_logger(__name__)
-
-
-@acks_late_micro_short_task(
-    name=f"{__name__}.create_forum_notifications",
-    retry_on=(LockNotAcquiredException,),
-)
-@transaction.atomic
-def create_forum_notifications_celery(**kwargs):
-    # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
-    return create_forum_notifications(**kwargs)
-
 
 @lambda_task(retry_on=(LockNotAcquiredException,))
 def create_forum_notifications(
@@ -39,7 +25,7 @@ def create_forum_notifications(
     model = apps.get_model(app_label=app_label, model_name=model_name)
 
     if model not in (ForumPost, ForumTopic):
-        logger.error(
+        task_logger.error(
             f"Forum notifications can only be created for posts or topics, not for {model}"
         )
         return

app/grandchallenge/notifications/tasks.py

@@ -2,19 +2,12 @@
 from django.db.models import Count, F, Q
 from lambda_tasks.decorators import lambda_task
 
-from grandchallenge.core.celery import acks_late_micro_short_task
 from grandchallenge.profiles.models import (
     NotificationEmailOptions,
     UserProfile,
 )
 
 
-@acks_late_micro_short_task(name=f"{__name__}.send_unread_notification_emails")
-def send_unread_notification_emails_celery():
-    # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
-    return send_unread_notification_emails()
-
-
 @lambda_task
 def send_unread_notification_emails():
     site = Site.objects.get_current()

app/grandchallenge/statistics/tasks.py

@@ -15,7 +15,6 @@
 from grandchallenge.cases.models import Image, ImageFile
 from grandchallenge.challenges.models import Challenge
 from grandchallenge.components.models import ComponentInterfaceValue
-from grandchallenge.core.celery import acks_late_micro_short_task
 from grandchallenge.evaluation.models import (
     EvaluationGroundTruth,
     Method,
@@ -30,12 +29,6 @@
 from grandchallenge.workstations.models import Session, WorkstationImage
 
 
-@acks_late_micro_short_task(name=f"{__name__}.update_site_statistics_cache")
-def update_site_statistics_cache_celery():
-    # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
-    return update_site_statistics_cache()
-
-
 @lambda_task
 def update_site_statistics_cache():
     public_challenges = Challenge.objects.filter(hidden=False)