您好!请教在异步任务中,在下方代码之后的代码都不会被执行,是否属于正常,万分感激!
async with self.api.register_update_notify([quote, kline, position]) as update_chan: async for _ in update_chan:
完整示例
async def doStrategy(self, symbol,):
quote = await self.api.get_quote(symbol)
kline = await self.api.get_kline_serial(symbol, 60, 500)
position = self.api.get_position(symbol)
target_pos = TargetPosTask(self.api, symbol)
last_pos = position.pos
async with self.api.register_update_notify([quote, kline, position]) as update_chan:
async for _ in update_chan:
if self.api.is_changing(position, ['pos', 'pos_long', 'pos_short']):
self.logger.info('[POS ACTUAL] %s from %d to %d' % (symbol, last_pos, position.pos))
last_pos = position.pos
#此处之后代码不会被执行
self.logger.info('strategy end.')
st2021forever 更改状态以发布 2022年9月6日