Python async code not working

Can someone help me understand why following code does not work. I am using Couchbase 6.5.1 and Python 3.0 SDK.

import asyncio
from acouchbase.cluster import Cluster
from couchbase.cluster import ClusterOptions
from couchbase.cluster import PasswordAuthenticator

async def do_crud_op():
    cb = Cluster.connect("couchbase://localhost", options=ClusterOptions(PasswordAuthenticator("user", "password")))
    cb = cb.bucket('customers')
    await cb.upsert('id', {'some': 'value'})
    return await cb.get('id')

loop = asyncio.get_event_loop()
rv = loop.run_until_complete(do_crud_op())

Hi @shivshankar_dayal - sorry again for the delay in response - I have attempted to answer this on the other thread you raised here: Connection issue with Couchbase 6.5.1 and Python 3.0.0