pikers
/
piker
4
1
Fork 0
Code Issues 10 Pull Requests 14 Packages Projects Releases Wiki Activity

Breakpoint when bad 1m history offsets are detected

samplerd_service
Tyler Goodlet 2023-01-05 15:09:31 -05:00
parent a746258f99
commit 78c7c8524c
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
piker/data/feed.py
View File

@ -126,7 +126,7 @@ class _FeedsBus(Struct):
target: Awaitable, target: Awaitable,
*args, *args,
) -> None: ) -> trio.CancelScope:
async def start_with_cs( async def start_with_cs(
task_status: TaskStatus[ task_status: TaskStatus[
@ -308,6 +308,11 @@ async def start_backfill(
- pendulum.from_timestamp(times[-2]) - pendulum.from_timestamp(times[-2])
).seconds ).seconds
if step_size_s == 60:
inow = round(time.time())
if (inow - times[-1]) > 60:
await tractor.breakpoint()
# frame's worth of sample-period-steps, in seconds # frame's worth of sample-period-steps, in seconds
frame_size_s = len(array) * step_size_s frame_size_s = len(array) * step_size_s