Emit backfill details in broadcasts
Send both the `Viz.name` and `timeframe: int` so that the UI side can match against them and only update a lone curve in a single plot.basic_buy_bot
parent
2a1835843f
commit
dd3e4b5a1f
|
@ -294,7 +294,7 @@ async def start_backfill(
|
||||||
)
|
)
|
||||||
await sampler_stream.send({
|
await sampler_stream.send({
|
||||||
'broadcast_all': {
|
'broadcast_all': {
|
||||||
'backfilling': True
|
'backfilling': (mkt.fqme, timeframe),
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
|
|
||||||
|
@ -323,7 +323,7 @@ async def start_backfill(
|
||||||
)
|
)
|
||||||
await sampler_stream.send({
|
await sampler_stream.send({
|
||||||
'broadcast_all': {
|
'broadcast_all': {
|
||||||
'backfilling': True
|
'backfilling': (mkt.fqme, timeframe),
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
|
|
||||||
|
@ -417,7 +417,7 @@ async def start_backfill(
|
||||||
# loop
|
# loop
|
||||||
await sampler_stream.send({
|
await sampler_stream.send({
|
||||||
'broadcast_all': {
|
'broadcast_all': {
|
||||||
'backfilling': True
|
'backfilling': (mkt.fqme, timeframe),
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
gap_indices: tuple | None = detect_null_time_gap(shm)
|
gap_indices: tuple | None = detect_null_time_gap(shm)
|
||||||
|
|
Loading…
Reference in New Issue