small fix in protocol
This commit is contained in:
parent
b92b98af29
commit
1595e5fd8a
@ -181,6 +181,7 @@ class ClientProtocol:
|
|||||||
async def _handle_default(self, name, type, data):
|
async def _handle_default(self, name, type, data):
|
||||||
key, la, df = data['key'], data['la'], data['df']
|
key, la, df = data['key'], data['la'], data['df']
|
||||||
|
|
||||||
|
if not df.empty:
|
||||||
columns = ", ".join([str(column) for column in df.columns])
|
columns = ", ".join([str(column) for column in df.columns])
|
||||||
|
|
||||||
self.logger.info(key)
|
self.logger.info(key)
|
||||||
@ -275,6 +276,7 @@ async def create_client(
|
|||||||
logger.error("Unexpected error has occurred:")
|
logger.error("Unexpected error has occurred:")
|
||||||
logger.exception(e)
|
logger.exception(e)
|
||||||
|
|
||||||
|
await asyncio.sleep(sleep_time)
|
||||||
continue
|
continue
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user