Function _build_forward_error

backend/data_process/tasks.py:364–376

(
    message: str,
    index_name: str,
    source: Optional[str],
    original_filename: Optional[str],
)

def _build_forward_error(
    message: str,
    index_name: str,
    source: Optional[str],
    original_filename: Optional[str],
) -> Exception:
    return Exception(json.dumps({
        "message": message,
        "index_name": index_name,
        "task_name": "forward",
        "source": source,
        "original_filename": original_filename
    }, ensure_ascii=False))


def _parse_json_or_none(text: str) -> Optional[Dict[str, Any]]: