pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Drop old bps from fsp engine

vlm_plotz_backup
Tyler Goodlet 2021-10-22 12:08:51 -04:00
parent df2dc4d1c5
commit 521b995530
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
piker/fsp/_engine.py
View File

@ -115,7 +115,6 @@ async def fsp_compute(
# and get historical output # and get historical output
history_output = await out_stream.__anext__() history_output = await out_stream.__anext__()
# await tractor.breakpoint()
profiler(f'{func_name} generated history') profiler(f'{func_name} generated history')
# build a struct array which includes an 'index' field to push # build a struct array which includes an 'index' field to push
@ -305,8 +304,6 @@ async def cascade(
return tracker, step_diff return tracker, step_diff
s, step, ld = is_synced(src, dst) s, step, ld = is_synced(src, dst)
if step or ld:
await tractor.breakpoint()
# Increment the underlying shared memory buffer on every # Increment the underlying shared memory buffer on every
# "increment" msg received from the underlying data feed. # "increment" msg received from the underlying data feed.