async def METHOD_NAME(
    db_connection: SAConnection,
    db_notification_queue: asyncio.Queue,
    task_class: NodeClass,
) -> dict:
    result = await db_connection.execute(
        comp_tasks.insert()
        .values(outputs=json.dumps({}), node_class=task_class)
        .returning(literal_column("*"))
    )
    row: RowProxy = await result.fetchone()
    METHOD_NAME = dict(row)
    assert (
        db_notification_queue.empty()
    ), "database triggered change although it should only trigger on updates!"
    yield METHOD_NAME