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

Drop old bps from fsp engine

fsp_drunken_alignment
Tyler Goodlet 2021-10-22 12:08:51 -04:00
parent c9136e0494
commit cbec7df225
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

@ -114,7 +114,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
@ -304,8 +303,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.