Function process_report_request

app/celery/tasks.py:671–703

(self, service_id: UUID, report_request_id: UUID)

@notify_celery.task(bind=True, name="process-report-request")
def process_report_request(self, service_id: UUID, report_request_id: UUID):
    report_request = dao_get_report_request_by_id(service_id=service_id, report_id=report_request_id)

    extra = {
        "report_request_id": report_request_id,
        "report_request_status": report_request.status,
        "celery_task": self.name,
    }
    current_app.logger.info(
        "Starting %(celery_task)s task for report request id %(report_request_id)s and "
        "status %(report_request_status)s",
        extra,
        extra=extra,
    )

    if report_request.status != REPORT_REQUEST_PENDING:
        return

    report_request.status = REPORT_REQUEST_IN_PROGRESS
    dao_update_report_request(report_request)

    try:
        ReportRequestProcessor(service_id=service_id, report_request_id=report_request_id).process()
        report_request.status = REPORT_REQUEST_STORED
        dao_update_report_request(report_request)

        current_app.logger.info(
            "Report request %s succeeded", report_request_id, extra={"report_request_id": report_request_id}
        )
    except Exception as e:
        report_request.status = REPORT_REQUEST_FAILED
        dao_update_report_request(report_request)
        raise ProcessReportRequestException(f"Report request for id {report_request_id} failed") from e