Asyncio корректное завершение в случае непредвиденной остановки программы

@asyncio.coroutine
def do_work(data):
    for adres, ip_list in data.items():
        if len(ip_list) >3:
            tasks = []
            for ip in ip_list:
                task = asyncio.async(walk_to_ip(ip))
                tasks.append(task)
            responses = yield from asyncio.gather(*tasks)
            res = set([bool(x) for x in responses])
 
            if len(res) == 1 and res == set([False]):
                print(adres, 'Bad',len(ip_list) )
            else:
                print(adres, 'OK' )
 
if __name__ == '__main__':
    data = get_data()
    try:
 
        loop = asyncio.get_event_loop()
        loop.run_until_complete(do_work(data))
        
    except Exception as e:
        print(e)
    finally:
        loop.close()

Traceback (most recent call last):
  File "total_monitor.py", line 108, in <module>
    loop.run_until_complete(do_work(data))
  File "/usr/lib/python3.4/asyncio/base_events.py", line 304, in run_until_complete
    self.run_forever()
  File "/usr/lib/python3.4/asyncio/base_events.py", line 276, in run_forever
    self._run_once()
  File "/usr/lib/python3.4/asyncio/base_events.py", line 1136, in _run_once
    event_list = self._selector.select(timeout)
  File "/usr/lib/python3.4/selectors.py", line 432, in select
    fd_event_list = self._epoll.poll(timeout, max_ev)
KeyboardInterrupt
Exception ignored in: Exception ignored in: Exception ignored in: Exception ignored in: Task was destroyed but it is pending!
task: <Task pending coro=<walk_to_ip() running at total_monitor.py:74> wait_for=<_GatheringFuture pending cb=[Task._wakeup()]> cb=[gather.<locals>._done_callback(5)() at /usr/lib/python3.4/asyncio/tasks.py:587]>
Task was destroyed but it is pending!
task: <Task pending coro=<walk_to_ip() running at total_monitor.py:74> wait_for=<_GatheringFuture pending cb=[Task._wakeup()]> cb=[gather.<locals>._done_callback(4)() at /usr/lib/python3.4/asyncio/tasks.py:587]>

@asyncio.coroutine
def do_work(data):
    for adres, ip_list in data.items():
        if len(ip_list) >3:
            tasks = []
            for ip in ip_list:
                task = asyncio.async(walk_to_ip(ip))
                tasks.append(task)
            responses = yield from asyncio.gather(*tasks)
            res = set([bool(x) for x in responses])
 
            if len(res) == 1 and res == set([False]):
                print(adres, 'Bad',len(ip_list) )
            else:
                print(adres, 'OK' )
 
if __name__ == '__main__':
    data = get_data()
    loop = asyncio.get_event_loop()
    try:        
        loop.run_until_complete(do_work(data))
        
    except Exception as e:
        loop.stop()
        pending = asyncio.Task.all_tasks()
        loop.run_until_complete(asyncio.gather(*pending))
        logger.debug('error - {}'.format(e))
    finally:
        loop.stop()
    loop.close()

import sys
 
_old_excepthook = sys.excepthook
def myexcepthook(exctype, value, traceback):
    if exctype == KeyboardInterrupt:
        pass  #...
    else:
        _old_excepthook(exctype, value, traceback)
sys.excepthook = myexcepthook