example.py

import asyncio
import signal
 
async def polling():
    print('polling...')
    await asyncio.sleep(3)
    asyncio.ensure_future(polling())

loop = asyncio.get_event_loop()
loop.create_task(polling())
loop.add_signal_handler(signal.SIGINT, loop.stop)


try:
    loop.run_forever()
except KeyboardInterrupt:
    # Calling loop.close() I get the warning below:
    # Task was destroyed but it is pending!
    # task: <Task pending coro=<polling() done, defined at...
    loop.close()