pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

Don't verify the history step period for now in `tsdb_backfill()`

account_tests
Tyler Goodlet 2023-07-10 17:57:32 -04:00
parent 06c581bfab
commit 8b9494281d
1 changed files with 15 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
piker/data/history.py
View File

@ -140,9 +140,7 @@ async def shm_push_in_between(
# memory... # memory...
array = shm.array array = shm.array
zeros = array[array['low'] == 0] zeros = array[array['low'] == 0]
if ( if 0 < zeros.size < 1000:
0 < zeros.size < 1000
):
tractor.breakpoint() tractor.breakpoint()
@ -637,20 +635,21 @@ async def tsdb_backfill(
task_status.started() task_status.started()
return return
times: np.ndarray = array['time'] # NOTE: removed for now since it'll always break
# on the first 60s of the venue open..
# times: np.ndarray = array['time']
# # sample period step size in seconds
# step_size_s = (
# from_timestamp(times[-1])
# - from_timestamp(times[-2])
# ).seconds
# sample period step size in seconds # if step_size_s not in (1, 60):
step_size_s = ( # log.error(f'Last 2 sample period is off!? -> {step_size_s}')
from_timestamp(times[-1]) # step_size_s = (
- from_timestamp(times[-2]) # from_timestamp(times[-2])
).seconds # - from_timestamp(times[-3])
# ).seconds
if step_size_s not in (1, 60):
log.error(f'Last 2 sample period is off!? -> {step_size_s}')
step_size_s = (
from_timestamp(times[-2])
- from_timestamp(times[-3])
).seconds
# NOTE: on the first history, most recent history # NOTE: on the first history, most recent history
# frame we PREPEND from the current shm ._last index # frame we PREPEND from the current shm ._last index