Коннектор к API используя AsyncIO, aiohttp

import asyncio
import aiohttp
import json
 
async def fetch(url, data=None, proxy=None):
    headers = {"content-type": "application/json"}
    async with aiohttp.ClientSession() as session:
        async with session.post(url, data=json.dumps(data), headers=headers) as response:
            if response.status == 200:
                print(await response.text())
                try:
                    jdata = await response.json()
                except (ValueError, AttributeError) as error:
                    LOG.error(error)
                else:
                    if jdata['ok']:
                        return jdata['result']
                    else:
                        LOG.error(jdata)
            else:
                print('ERRRR')
                print(await response.text())
 
def _todict(params, more=[]):
    return {key: value for key, value in params.items() if key not in ['self'] + more}
 
class telega(object):
 
    def __init__(self, token, offset = 0):
        self.token = token
        self.offset = offset
        self._runnable = True
 
    def _msgurl(self, method):
        return '{url}{token}/{method}'.format(
            url='https://api.telegram.org/bot',
            token=self.token,
            method=method)
 
    def _fileurl(self, method):
        return '{url}{token}/{method}'.format(
            url='https://api.telegram.org/file/bot',
            token=self.token,
            method=method)
 
    def message(func):
        def decorator(self, *args, **kwargs):
            url, data = func(self, *args, **kwargs)
            return fetch(url, data)
        return decorator
 
    @message
    def get_me(self):
        method = 'getMe'
        return self._msgurl(method), None
 
    @message
    def get_updates(self, offset=None, limit=100, timeout=30):
        method = 'getUpdates'
        data = _todict(locals())
        return self._msgurl(method), data
 
    @message
    def send_message(self, chat_id, text, **kwargs):
        method = 'sendMessage'
        data = _todict(locals())
        return self._msgurl(method), data
 
    async def processing(self, msg):
        await asyncio.sleep(10)
        await self.send_message(msg['message']['chat']['id'], 'sleep 10 sec stop')
 
    async def check_updates(self):
        print(await self.get_me())
        while self._runnable:
            upd = await self.get_updates(self.offset+1)
            for msg in upd:
                await self.send_message(msg['message']['chat']['id'], msg['message']['text'])
                await self.processing(msg)
                self.offset = msg['update_id']
 
    def run(self):
        loop = asyncio.get_event_loop()
        loop.run_until_complete(self.check_updates())
        loop.run_forever()
 
if __name__ == '__main__':
    bot = telega('token')
    bot.run()