From be93ded0e5b7afd2d43df9ebf5c3196b06d432d8 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Fri, 28 Jan 2022 07:43:23 -0500
Subject: [PATCH] Log fsp registy entries in `cascade` startup

---
 piker/fsp/_api.py    |  2 --
 piker/fsp/_engine.py | 12 +++++++-----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/piker/fsp/_api.py b/piker/fsp/_api.py
index 05bb3f99..af57d2f8 100644
--- a/piker/fsp/_api.py
+++ b/piker/fsp/_api.py
@@ -26,7 +26,6 @@ FSP (financial signal processing) apis.
 
 from __future__ import annotations
 from functools import partial
-from pprint import pformat
 from typing import (
     Any,
     Callable,
@@ -56,7 +55,6 @@ def _load_builtins() -> dict[tuple, Callable]:
     from . import _momo  # noqa
     from . import _volume  # noqa
 
-    log.info(f'Registered FSP set:\n{pformat(_fsp_registry)}')
     return _fsp_registry
 
 
diff --git a/piker/fsp/_engine.py b/piker/fsp/_engine.py
index dac672bb..53c872e8 100644
--- a/piker/fsp/_engine.py
+++ b/piker/fsp/_engine.py
@@ -34,8 +34,7 @@ from .. import data
 from ..data import attach_shm_array
 from ..data.feed import Feed
 from ..data._sharedmem import ShmArray
-# from ._momo import _rsi, _wma
-# from ._volume import _tina_vwap, dolla_vlm
+from ._api import Fsp
 from ._api import _load_builtins
 
 log = get_logger(__name__)
@@ -78,7 +77,6 @@ async def fsp_compute(
     src: ShmArray,
     dst: ShmArray,
 
-    # func_name: str,
     func: Callable,
 
     attach_stream: bool = False,
@@ -216,8 +214,12 @@ async def cascade(
     src = attach_shm_array(token=src_shm_token)
     dst = attach_shm_array(readonly=False, token=dst_shm_token)
 
-    # func: Callable = _fsp_builtins.get(tuple(ns_path))
-    func: Fsp = _load_builtins().get(
+    reg = _load_builtins()
+    lines = '\n'.join([f'{key.rpartition(":")[2]} => {key}' for key in reg])
+    log.info(
+        f'Registered FSP set:\n{lines}'
+    )
+    func: Fsp = reg.get(
         NamespacePath(ns_path)
     )