Replacing asyncio.get_event_loop().run_until_complete with ayncio.run

The issue here lies in how the event loop is managed. asyncio.run always creates a brand new event loop internally. The API you're using seems like it uses asyncio.get_event_loop() in the Exchange class which creates a different event loop from the one asyncio.run creates and passes that one around. This causes problems, as the loop that the Exchange class created is just sitting there idle, so trying to run anything with that loop won't really run. To fix this, you need to ensure you're using the loop that asyncio.run creates, which means refactoring the code a bit and using asyncio.get_running_loop(). asyncio.get_running_loop() will return the currently running loop or throw an exception if one is not running, it will never create a new one.

To specifically fix the issue you have (bear in mind, this change may break other areas of the code)

Change the constructor of the Exchange class in exchange.py to use asyncio.get_running_loop() instead of asyncio.get_event_loop() like so:

class Exchange(BaseExchange):

    def __init__(self, config={}):
        if 'asyncio_loop' in config:
            self.asyncio_loop = config['asyncio_loop']
        self.asyncio_loop = asyncio.get_running_loop() #this is the change here, note that this overwrites the loop from the config, so this could cause problems.
        self.aiohttp_trust_env = config.get('aiohttp_trust_env', self.aiohttp_trust_env)
        self.verify = config.get('verify', self.verify)
        self.own_session = 'session' not in config
        self.cafile = config.get('cafile', certifi.where())
        super(Exchange, self).__init__(config)
        self.throttle = None
        self.init_rest_rate_limiter()
        self.markets_loading = None
        self.reloading_markets = False

Next, you'll need to move your exchange init code into the main coroutine. This is so that when the constructor calls get_running_loop it will return the loop that asyncio.run created:

async def main():

  # instantiate all exchanges
  for id in ccxt.exchanges:
    if id == 'theocean':
      continue
    exchange = getattr(ccxt, id)
    exchange_config = {'verbose': argv.verbose}
    if sys.version_info[0] < 3:
      exchange_config.update({'enableRateLimit': True})
    if id in config:
      exchange_config = ccxt.Exchange.deep_extend(exchange_config, config[id])
    exchanges[id] = exchange(exchange_config)
    #other code as before...

This fix works, but bear in mind that the API itself may need to be refactored in a way that supports the way it handles the event loop to support the way asyncio.run creates and manages the event loop. In particular, the code in the Exchange class that can pull an event loop from a config may need to be refactored.