async def METHOD_NAME(
    project_id: str, node_uuid: str, connection: aiopg.sa.SAConnection
) -> RowProxy:
    log.debug(
        "Reading from comp_tasks table for node uuid %s, project %s",
        node_uuid,
        project_id,
    )
    result = await connection.execute(
        sa.select(comp_tasks).where(
            and_(
                comp_tasks.c.node_id == node_uuid,
                comp_tasks.c.project_id == project_id,
            )
        )
    )
    if result.rowcount > 1:
        log.error("the node id %s is not unique", node_uuid)
    node: RowProxy | None = await result.first()
    if not node:
        log.error("the node id %s was not found", node_uuid)
        raise NodeNotFound(node_uuid)
    return node