From f88fe14eb290dcd6f7d485dbc8c48b28ba75354d Mon Sep 17 00:00:00 2001 From: Tom McLean Date: Wed, 4 Oct 2023 17:44:46 +0100 Subject: [PATCH] feat: Convert live price listener to websockets --- vega_sim/scenario/common/utils/price_process.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/vega_sim/scenario/common/utils/price_process.py b/vega_sim/scenario/common/utils/price_process.py index 64de5b032..747da90cf 100644 --- a/vega_sim/scenario/common/utils/price_process.py +++ b/vega_sim/scenario/common/utils/price_process.py @@ -178,13 +178,9 @@ def get_historic_price_series( def _price_listener(iter_obj, symbol): ws = websocket.WebSocketApp( f"wss://stream.binance.com:9443/ws/{symbol}@kline_1s", - # on_open=lambda ws: print("ok"), on_message=lambda _, msg: _on_message(iter_obj, msg), - # on_error=on_error, - # on_close=on_close, ) ws.run_forever(reconnect=5) - # self._forwarding_thread.start() def _on_message(iter_obj, message):