serializers.py

import psycopg2


async def create_domain(conn, data):
    sql = "INSERT INTO domains (name) VALUES (%s) ON CONFLICT DO NOTHING RETURNING *"
    async with conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor) as cursor:
        await cursor.execute(sql, [data["name"]])
        domain = await cursor.fetchone()
        return domain


def serialize_domain(data):
    return {"name": data["name"]}