def METHOD_NAME(self):
    """
    GIVEN:
        - A celery task is started via the consume folder
    WHEN:
        - Task starts execution
    THEN:
        - The task is marked as started
    """
    headers = {
        "id": str(uuid.uuid4()),
        "task": "documents.tasks.consume_file",
    }
    body = (
        # args
        (
            ConsumableDocument(
                source=DocumentSource.ConsumeFolder,
                original_file="/consume/hello-99.pdf",
            ),
            None,
        ),
        # kwargs
        {},
        # celery stuff
        {"callbacks": None, "errbacks": None, "chain": None, "chord": None},
    )
    self.util_call_before_task_publish_handler(
        headers_to_use=headers,
        body_to_use=body,
    )
    task_prerun_handler(task_id=headers["id"])
    task = PaperlessTask.objects.get()
    self.assertEqual(celery.states.STARTED, task.status)