Pass tsdb flag when db is up XD
parent
57acc3bd29
commit
a7ff47158b
piker/data
|
@ -338,7 +338,7 @@ async def start_backfill(
|
||||||
log.debug(f'New datetime index:\n{pformat(dtrange)}')
|
log.debug(f'New datetime index:\n{pformat(dtrange)}')
|
||||||
|
|
||||||
for end_dt in dtrange:
|
for end_dt in dtrange:
|
||||||
log.warning(f'Yielding next frame start {end_dt}')
|
log.info(f'Yielding next frame start {end_dt}')
|
||||||
start = yield end_dt
|
start = yield end_dt
|
||||||
|
|
||||||
# if caller sends a new start date, reset to that
|
# if caller sends a new start date, reset to that
|
||||||
|
@ -722,6 +722,7 @@ async def manage_history(
|
||||||
bfqsn,
|
bfqsn,
|
||||||
shm,
|
shm,
|
||||||
last_tsdb_dt=last_tsdb_dt,
|
last_tsdb_dt=last_tsdb_dt,
|
||||||
|
tsdb_is_up=True,
|
||||||
storage=storage,
|
storage=storage,
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
Loading…
Reference in New Issue