Delete incomplete file uploads

care/facility/models/file_upload.py

@@ -124,3 +124,13 @@ def get_object(self, bucket=settings.FILE_UPLOAD_BUCKET, **kwargs):
             Key=f"{self.FileType(self.file_type).name}/{self.internal_name}",
             **kwargs,
         )
+
+    @staticmethod
+    def bulk_delete_objects(s3_keys):
+        s3 = boto3.client("s3", **cs_provider.get_client_config())
+        bucket = settings.FILE_UPLOAD_BUCKET
+
+        return s3.delete_objects(
+            Bucket=bucket,
+            Delete={"Objects": [{"Key": key} for key in s3_keys], "Quiet": True},
+        )

care/facility/tasks/fileupload/delete_incomplete_file_uploads.py

@@ -0,0 +1,25 @@
+from datetime import timedelta
+
+from celery.decorators import periodic_task
+from celery.schedules import crontab
+from django.utils import timezone
+
+from care.facility.models.file_upload import FileUpload
+
+
+@periodic_task(
+    run_every=crontab(minute="0", hour="0")
+)  # Run the task daily at midnight
+def delete_incomplete_file_uploads():
+    yesterday = timezone.now() - timedelta(days=1)
+    incomplete_uploads = FileUpload.objects.filter(
+        created__date__lte=yesterday, upload_completed=False
+    )
+
+    s3_keys = [
+        f"{upload.FileType(upload.file_type).name/upload.internal_name}"
+        for upload in incomplete_uploads
+    ]
+
+    FileUpload.bulk_delete_objects(s3_keys)
+    incomplete_uploads.update(deleted=True)