piker/fsp/_engine.py

@@ -484,8 +484,7 @@ async def cascade(
     # open a data feed stream with requested broker
     feed: Feed
     async with data.feed.maybe_open_feed(
-        fqmes=[fqme],
+        [fqme],
-        loglevel=loglevel,
 
         # TODO throttle tick outputs from *this* daemon since
         # it'll emit tons of ticks due to the throttle only
@@ -583,8 +582,7 @@ async def cascade(
                     # on every step msg received from the global `samplerd`
                     # service.
                     async with open_sample_stream(
-                        period_s=float(delay_s),
+                        float(delay_s)
-                        loglevel=loglevel,
                     ) as istream:
 
                         profiler(f'{func_name}: sample stream up')

piker/ui/_display.py

@@ -21,7 +21,6 @@ this module ties together quote and computational (fsp) streams with
 graphics update methods via our custom ``pyqtgraph`` charting api.
 
 '''
-from functools import partial
 import itertools
 from math import floor
 import time
@@ -209,7 +208,6 @@ class DisplayState(Struct):
 async def increment_history_view(
     # min_istream: tractor.MsgStream,
     ds: DisplayState,
-    loglevel: str = 'warning',
 ):
     hist_chart: ChartPlotWidget = ds.hist_chart
     hist_viz: Viz = ds.hist_viz
@@ -231,10 +229,7 @@ async def increment_history_view(
         hist_viz.reset_graphics()
         # hist_viz.update_graphics(force_redraw=True)
 
-    async with open_sample_stream(
+    async with open_sample_stream(1.) as min_istream:
-        period_s=1.,
-        loglevel=loglevel,
-    ) as min_istream:
         async for msg in min_istream:
 
             profiler = Profiler(
@@ -315,6 +310,7 @@ async def increment_history_view(
 
 
 async def graphics_update_loop(
+
     dss: dict[str, DisplayState],
     nurse: trio.Nursery,
     godwidget: GodWidget,
@@ -323,7 +319,6 @@ async def graphics_update_loop(
 
     pis: dict[str, list[pgo.PlotItem, pgo.PlotItem]] = {},
     vlm_charts: dict[str, ChartPlotWidget] = {},
-    loglevel: str = 'warning',
 
 ) -> None:
     '''
@@ -467,12 +462,9 @@ async def graphics_update_loop(
         # })
 
         nurse.start_soon(
-            partial(
             increment_history_view,
             # min_istream,
-                ds=ds,
+            ds,
-                loglevel=loglevel,
-            ),
         )
         await trio.sleep(0)
 
@@ -519,19 +511,14 @@ async def graphics_update_loop(
                     fast_chart.linked.isHidden()
                     or not rt_pi.isVisible()
                 ):
-                    log.debug(
+                    print(f'{fqme} skipping update for HIDDEN CHART')
-                        f'{fqme} skipping update for HIDDEN CHART'
-                    )
                     fast_chart.pause_all_feeds()
                     continue
 
                 ic = fast_chart.view._in_interact
                 if ic:
                     fast_chart.pause_all_feeds()
-                    log.debug(
+                    print(f'{fqme} PAUSING DURING INTERACTION')
-                        f'Pausing chart updaates during interaction\n'
-                        f'fqme: {fqme!r}'
-                    )
                     await ic.wait()
                     fast_chart.resume_all_feeds()
 
@@ -1604,18 +1591,15 @@ async def display_symbol_data(
             # start update loop task
             dss: dict[str, DisplayState] = {}
             ln.start_soon(
-                partial(
                 graphics_update_loop,
-                    dss=dss,
+                dss,
-                    nurse=ln,
+                ln,
-                    godwidget=godwidget,
+                godwidget,
-                    feed=feed,
+                feed,
                 # min_istream,
 
-                    pis=pis,
+                pis,
-                    vlm_charts=vlm_charts,
+                vlm_charts,
-                    loglevel=loglevel,
-                )
             )
 
             # boot order-mode

piker/ui/_fsp.py

@@ -183,17 +183,13 @@ async def open_fsp_sidepane(
 
 @acm
 async def open_fsp_actor_cluster(
-    names: list[str] = [
+    names: list[str] = ['fsp_0', 'fsp_1'],
-        'fsp_0',
-        'fsp_1',
-    ],
 
 ) -> AsyncGenerator[
     int,
     dict[str, tractor.Portal]
 ]:
 
-    # TODO! change to .experimental!
     from tractor._clustering import open_actor_cluster
 
     # profiler = Profiler(
@@ -201,7 +197,7 @@ async def open_fsp_actor_cluster(
     #     disabled=False
     # )
     async with open_actor_cluster(
-        count=len(names),
+        count=2,
         names=names,
         modules=['piker.fsp._engine'],
 
@@ -501,8 +497,7 @@ class FspAdmin:
 
         portal: tractor.Portal = (
             self.cluster.get(worker_name)
-            or
+            or self.rr_next_portal()
-            self.rr_next_portal()
         )
 
         # TODO: this should probably be turned into a

piker/ui/_widget.py

@@ -300,10 +300,7 @@ class GodWidget(QWidget):
         getattr(widget, 'on_resize')
         self._widgets[widget.mode_name] = widget
 
-    def on_win_resize(
+    def on_win_resize(self, event: QtCore.QEvent) -> None:
-        self,
-        event: QtCore.QEvent,
-    ) -> None:
         '''
         Top level god widget handler from window (the real yaweh) resize
         events such that any registered widgets which wish to be
@@ -318,10 +315,7 @@ class GodWidget(QWidget):
 
         self._resizing = True
 
-        log.debug(
+        log.info('God widget resize')
-            f'God widget resize\n'
-            f'{event}\n'
-        )
         for name, widget in self._widgets.items():
             widget.on_resize()
 

piker/ui/_window.py

@@ -255,16 +255,8 @@ class MainWindow(QMainWindow):
         current: QWidget,
 
     ) -> None:
-        '''
-        Focus handler.
 
-        For now updates the "current mode" name.
+        log.info(f'widget focus changed from {last} -> {current}')
-
-        '''
-        log.debug(
-            f'widget focus changed from,\n'
-            f'{last} -> {current}'
-        )
 
         if current is not None:
             # cursor left window?

piker/ui/cli.py

@@ -177,7 +177,7 @@ def chart(
             return
 
     # global opts
-    # brokernames: list[str] = config['brokers']
+    brokernames = config['brokers']
     brokermods = config['brokermods']
     assert brokermods
     tractorloglevel = config['tractorloglevel']
@@ -216,7 +216,6 @@ def chart(
                 layers['tcp']['port'],
             ))
 
-    # breakpoint()
     from tractor.devx import maybe_open_crash_handler
     pdb: bool = config['pdb']
     with maybe_open_crash_handler(pdb=pdb):

piker/ui/order_mode.py

@@ -513,14 +513,13 @@ class OrderMode:
     def on_submit(
         self,
         uuid: str,
-        order: Order|None = None,
+        order: Order | None = None,
 
-    ) -> Dialog|None:
+    ) -> Dialog | None:
         '''
         Order submitted status event handler.
 
-        Commit the order line and registered order uuid, store ack
+        Commit the order line and registered order uuid, store ack time stamp.
-        time stamp.
 
         '''
         lines = self.lines.commit_line(uuid)