Coverage for baibu/submissions/tasks.py: 100%

1from celery import shared_task 

2 

3from .models import Submission 

4from .services import run_cleaning 

5 

6 

7@shared_task(ignore_result=True) 

8def clean_submission(submission_id: str) -> str: 

9 submission = Submission.objects.filter(pk=submission_id).first() 

10 if submission is None: 

11 return "missing" 

12 return run_cleaning(submission).status