from __future__ import annotations

from app.services.document_processor import process_document
from app.worker.celery_app import celery_app


@celery_app.task(name="process_document_task")
def process_document_task(document_id: str) -> str:
    process_document(document_id)
    return document_id