update websocket exception caught in api_ws
This commit is contained in:
parent
f9b3b0ef77
commit
85edcaaad5
@ -134,13 +134,13 @@ async def message_endpoint(
|
|||||||
|
|
||||||
except (
|
except (
|
||||||
WebSocketDisconnect,
|
WebSocketDisconnect,
|
||||||
websockets.exceptions.ConnectionClosed
|
websockets.exceptions.WebSocketException
|
||||||
):
|
):
|
||||||
# Handle client disconnects
|
# Handle client disconnects
|
||||||
logger.info(f"Consumer disconnected - {channel}")
|
logger.info(f"Consumer disconnected - {channel}")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.info(f"Consumer connection failed - {channel}")
|
logger.info(f"Consumer connection failed - {channel}")
|
||||||
logger.exception(e)
|
logger.debug(e, exc_info=e)
|
||||||
# Handle cases like -
|
# Handle cases like -
|
||||||
# RuntimeError('Cannot call "send" once a closed message has been sent')
|
# RuntimeError('Cannot call "send" once a closed message has been sent')
|
||||||
finally:
|
finally:
|
||||||
|
@ -177,7 +177,7 @@ def test_get_producer_df(mocker, default_conf, ohlcv_history):
|
|||||||
assert la == empty_la
|
assert la == empty_la
|
||||||
|
|
||||||
# the data is added, should return that added dataframe
|
# the data is added, should return that added dataframe
|
||||||
dataprovider._add_external_df(pair, ohlcv_history, now, timeframe, candle_type)
|
dataprovider._add_producer_df(pair, ohlcv_history, now, timeframe, candle_type)
|
||||||
dataframe, la = dataprovider.get_producer_df(pair, timeframe, candle_type)
|
dataframe, la = dataprovider.get_producer_df(pair, timeframe, candle_type)
|
||||||
assert len(dataframe) > 0
|
assert len(dataframe) > 0
|
||||||
assert la > empty_la
|
assert la > empty_la
|
||||||
|
Loading…
Reference in New Issue
Block a user