diff --git a/piker/data/_sharedmem.py b/piker/data/_sharedmem.py index 5d38cbbd..9c515ce3 100644 --- a/piker/data/_sharedmem.py +++ b/piker/data/_sharedmem.py @@ -394,6 +394,7 @@ def open_shm_array( # "unlink" created shm on process teardown by # pushing teardown calls onto actor context stack + tractor._actor._lifetime_stack.callback(shmarr.close) tractor._actor._lifetime_stack.callback(shmarr.destroy) diff --git a/piker/data/_source.py b/piker/data/_source.py index 46302508..8ec92dfd 100644 --- a/piker/data/_source.py +++ b/piker/data/_source.py @@ -133,9 +133,11 @@ def mk_symbol( def from_df( + df: pd.DataFrame, source=None, default_tf=None + ) -> np.recarray: """Convert OHLC formatted ``pandas.DataFrame`` to ``numpy.recarray``.