`kraken`: the apiflows chain map needs a `dict`
parent
9486d993ce
commit
e6dd1458f8
|
@ -795,7 +795,7 @@ async def handle_order_updates(
|
||||||
# 'vol_exec': exec_vlm} # 0.0000
|
# 'vol_exec': exec_vlm} # 0.0000
|
||||||
match update_msg:
|
match update_msg:
|
||||||
|
|
||||||
# EMS-unknown live order that needs to be
|
# EMS-unknown LIVE order that needs to be
|
||||||
# delivered and loaded on the client-side.
|
# delivered and loaded on the client-side.
|
||||||
case {
|
case {
|
||||||
'userref': reqid,
|
'userref': reqid,
|
||||||
|
@ -849,7 +849,7 @@ async def handle_order_updates(
|
||||||
),
|
),
|
||||||
src='kraken',
|
src='kraken',
|
||||||
)
|
)
|
||||||
apiflows[reqid].maps.append(status_msg)
|
apiflows[reqid].maps.append(status_msg.to_dict())
|
||||||
await ems_stream.send(status_msg)
|
await ems_stream.send(status_msg)
|
||||||
continue
|
continue
|
||||||
|
|
||||||
|
@ -1104,7 +1104,6 @@ async def handle_order_updates(
|
||||||
'txid': [txid],
|
'txid': [txid],
|
||||||
})
|
})
|
||||||
case _:
|
case _:
|
||||||
|
|
||||||
log.warning(f'Unhandled trades update msg: {msg}')
|
log.warning(f'Unhandled trades update msg: {msg}')
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue