@ -42,12 +42,8 @@ def main_loop():
loop.add_signal_handler(getattr(signal, signame),
partial(on_signal, signame))
try:
loop.run_until_complete(future)
except asyncio.CancelledError:
pass
finally:
loop.close()
def main():
@ -388,7 +388,6 @@ class BlockProcessor(server.db.DB):
self.on_cancel()
# This lets the asyncio subsystem process futures cancellations
await asyncio.sleep(0)
raise
def on_cancel(self):
'''Called when the main loop is cancelled.