File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -583,16 +583,6 @@ def handle_dicom_import_error(
583583 )
584584
585585
586- @acks_late_micro_short_task (
587- name = f"{ __name__ } .handle_health_imaging_import_job_event" ,
588- retry_on = (LockNotAcquiredException , RetryStep ),
589- )
590- @transaction .atomic
591- def handle_health_imaging_import_job_event_celery (* , event ):
592- # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
593- return handle_health_imaging_import_job_event (event = event )
594-
595-
596586@lambda_task (retry_on = (LockNotAcquiredException , RetryStep ))
597587def handle_health_imaging_import_job_event (* , event : dict ):
598588 job_name = event ["jobName" ]
Original file line number Diff line number Diff line change @@ -35,15 +35,6 @@ def create_codebuild_build(*, pk):
3535 Build .objects .create (webhook_message = ghwm , algorithm_image = algorithm_image )
3636
3737
38- @acks_late_micro_short_task (name = f"{ __name__ } .handle_completed_build_event" )
39- @transaction .atomic
40- def handle_completed_build_event_celery (* , build_arn , build_status ):
41- # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
42- return handle_completed_build_event (
43- build_arn = build_arn , build_status = build_status
44- )
45-
46-
4738@lambda_task
4839def handle_completed_build_event (* , build_arn : str , build_status : str ):
4940 from grandchallenge .codebuild .models import Build
Original file line number Diff line number Diff line change 11from datetime import timedelta
22
33import boto3
4- from billiard .exceptions import (
5- SoftTimeLimitExceeded as CelerySoftTimeLimitExceeded ,
6- )
74from django .conf import settings
85from django .contrib .sites .models import Site
96from django .db import transaction
@@ -37,23 +34,6 @@ def cleanup_celery_backend():
3734CLOUDWATCH_METRICS_LIMIT = 1000
3835
3936
40- @acks_late_micro_short_task (
41- name = f"{ __name__ } .put_cloudwatch_metrics" ,
42- ignore_result = True ,
43- singleton = True ,
44- # No need to retry here as the periodic task call this again
45- ignore_errors = (
46- LockError ,
47- CelerySoftTimeLimitExceeded ,
48- SoftTimeLimitExceeded ,
49- ),
50- )
51- @transaction .atomic
52- def put_cloudwatch_metrics_celery ():
53- # TODO: 4408 Remove, this is still here to handle existing tasks on SQS
54- return put_cloudwatch_metrics ()
55-
56-
5737@lambda_task (
5838 singleton = True ,
5939 # No need to retry here as the periodic task call this again
You can’t perform that action at this time.
0 commit comments