connector

This commit is contained in:
4tochka 2019-05-04 14:02:01 +04:00
parent fc85f9022b
commit fa8759f5ad

View File

@ -433,7 +433,7 @@ class Connector:
if self.await_tx:
self.await_tx = set()
for i in self.await_tx_future:
if not self.await_tx_future.done():
if not self.await_tx_future[i].done():
self.await_tx_future[i].cancel()
self.await_tx_future = dict()
self.log.error(str(traceback.format_exc()))