Skip to content

Commit aac29bf

Browse files
committed
Migrate short uploads app tasks
1 parent fa011c7 commit aac29bf

2 files changed

Lines changed: 8 additions & 5 deletions

File tree

app/config/settings.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1249,10 +1249,6 @@ def get_private_ip():
12491249
"task": "grandchallenge.challenges.tasks.update_challenge_compute_costs",
12501250
"schedule": crontab(minute=45),
12511251
},
1252-
"delete_old_user_uploads": {
1253-
"task": "grandchallenge.uploads.tasks.delete_old_user_uploads",
1254-
"schedule": timedelta(hours=1),
1255-
},
12561252
"cleanup_sent_raw_emails": {
12571253
"task": "grandchallenge.emails.tasks.cleanup_sent_raw_emails",
12581254
"schedule": timedelta(hours=1),

app/grandchallenge/uploads/tasks.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,20 @@
33
from django.conf import settings
44
from django.db import transaction
55
from django.utils.timezone import now
6+
from lambda_tasks.decorators import lambda_task
67

78
from grandchallenge.core.celery import acks_late_micro_short_task
89
from grandchallenge.uploads.models import UserUpload
910

1011

11-
@acks_late_micro_short_task
12+
@acks_late_micro_short_task(name=f"{__name__}.delete_old_user_uploads")
1213
@transaction.atomic
14+
def delete_old_user_uploads_celery(**kwargs):
15+
# TODO: 4408 Remove, this is still here to handle existing tasks on SQS
16+
return delete_old_user_uploads(**kwargs)
17+
18+
19+
@lambda_task
1320
def delete_old_user_uploads():
1421
UserUpload.objects.filter(
1522
created__lt=now() - timedelta(days=settings.UPLOADS_TIMEOUT_DAYS)

0 commit comments

Comments
 (0)