|
|
@ -123,9 +123,9 @@ class DictProtocol(asyncio.Protocol):
|
|
|
|
except KeyError:
|
|
|
|
except KeyError:
|
|
|
|
return await self.reply(b"F")
|
|
|
|
return await self.reply(b"F")
|
|
|
|
except Exception as e:
|
|
|
|
except Exception as e:
|
|
|
|
logging.error(f"Got {e}, cancelling remaining tasks")
|
|
|
|
|
|
|
|
for task in rows:
|
|
|
|
for task in rows:
|
|
|
|
task.cancel()
|
|
|
|
task.cancel()
|
|
|
|
|
|
|
|
raise e
|
|
|
|
|
|
|
|
|
|
|
|
def process_begin(self, transaction_id, user=None):
|
|
|
|
def process_begin(self, transaction_id, user=None):
|
|
|
|
""" Process a dict begin message
|
|
|
|
""" Process a dict begin message
|
|
|
|