diff --git a/piker/fsp/_engine.py b/piker/fsp/_engine.py index 53c872e8..0a318a3e 100644 --- a/piker/fsp/_engine.py +++ b/piker/fsp/_engine.py @@ -107,8 +107,8 @@ async def fsp_compute( profiler(f'{func_name} generated history') # build struct array with an 'index' field to push as history - history = np.array( - np.arange(len(history_output)), + history = np.zeros( + len(history_output), dtype=dst.array.dtype )