use loop in socket.io callback
This commit is contained in:
parent
f8754e3f69
commit
d00dc19926
4
main.py
4
main.py
@ -65,7 +65,7 @@ def on_close_position(message: dict):
|
|||||||
|
|
||||||
|
|
||||||
@socketio.on('connect')
|
@socketio.on('connect')
|
||||||
async def on_connect():
|
def on_connect():
|
||||||
# sleeping on exception to avoid race condition
|
# sleeping on exception to avoid race condition
|
||||||
ticks, prices, positions, balances = [], [], [], []
|
ticks, prices, positions, balances = [], [], [], []
|
||||||
|
|
||||||
@ -74,7 +74,7 @@ async def on_connect():
|
|||||||
ticks = bot.symbol_status(Symbol.BTC).all_ticks()
|
ticks = bot.symbol_status(Symbol.BTC).all_ticks()
|
||||||
prices = bot.symbol_status(Symbol.BTC).all_prices()
|
prices = bot.symbol_status(Symbol.BTC).all_prices()
|
||||||
positions = bot.symbol_status(Symbol.BTC).current_positions()
|
positions = bot.symbol_status(Symbol.BTC).current_positions()
|
||||||
balances = await bot.get_balances()
|
balances = loop.run_until_complete(bot.get_balances())
|
||||||
except KeyError:
|
except KeyError:
|
||||||
sleep(1)
|
sleep(1)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user