Spurious first-draft of EG collapsing

Topically, throughout various (seemingly) console-UX-affecting or benign spots in the code base; nothing that required more intervention beyond things superficial. A few spots also include `trio.Nursery` ref renames (always to something with a `tn` in it) and log-level reductions to quiet (benign) console noise oriented around issues meant to be solved long.. Note there's still a couple spots i left with the loose-ify flag because i haven't fully tested them without using the latest version of `tractor.trionics.collapse_eg()`, but more then likely they should flip over fine.
Use `.trionics.collapse_eg()` in `.deribit.api`
2026-01-02 18:22:11 -05:00 · 2026-01-02 18:22:11 -05:00 · 2026-01-02 18:19:50 -05:00 · 2026-01-02 17:39:12 -05:00 · 2026-01-02 17:39:12 -05:00 · 2026-01-02 17:37:55 -05:00
57 changed files with 2404 additions and 1454 deletions
--- a/README.rst
+++ b/README.rst
@ -88,22 +88,57 @@ a sane install with `uv`
 ************************
 bc why install with `python` when you can faster with `rust` ::

-    uv lock
+    uv sync
+
+    # ^ astral's docs,
+    # https://docs.astral.sh/uv/concepts/projects/sync/
+
+include all GUIs (ex. for charting)::
+
+    uv sync --extra uis
+
+AND with all our hacking tools and WIP integrations::
+
+    uv sync --dev --all-extras 


-hacky install on nixos
-**********************
+Ensure you can run the root-daemon::
+
+    uv run pikerd [-l info --pdb]
+
+
+install on nix(os)
+******************
 ``NixOS`` is our core devs' distro of choice for which we offer
-a stringently defined development shell envoirment that can be loaded with::
+a stringently defined development shell envoirment that can currently
+be applied in one of 2 ways::

+    # ONLY if running on X11
    nix-shell default.nix

+Or if you prefer flakes style and a modern DE::
+
+    # ONLY if also running on Wayland
+    nix develop  # for default bash
+    nix develop -c uv run xonsh  # for @goodboy's preferred sh B)
+

 start a chart
 *************
 run a realtime OHLCV chart stand-alone::

-    piker -l info chart btcusdt.spot.binance xmrusdt.spot.kraken
+    [uv run] piker -l info chart btcusdt.spot.binance xmrusdt.spot.kraken
+
+    # ^^^ iff you haven't activated the py-env,
+    # - https://docs.astral.sh/uv/concepts/projects/run/
+    #
+    # in order to create an explicit virt-env see,
+    # - https://docs.astral.sh/uv/concepts/projects/layout/#the-project-environment
+    # - https://docs.astral.sh/uv/pip/environments/
+    #
+    # use $UV_PROJECT_ENVIRONMENT to select any non-`.venv/`
+    # as the venv sudir in the repo's root.
+    # - https://docs.astral.sh/uv/reference/environment/#uv_project_environment

 this runs a chart UI (with 1m sampled OHLCV) and shows 2 spot markets from 2 diff cexes
 overlayed on the same graph. Use of `piker` without first starting
--- a/default.nix
+++ b/default.nix
@ -11,11 +11,12 @@ let
  libxkbcommonStorePath = lib.getLib libxkbcommon;
  xcbutilcursorStorePath = lib.getLib xcb-util-cursor;

-  qtpyStorePath = lib.getLib python312Packages.qtpy;
-  pyqt6StorePath = lib.getLib python312Packages.pyqt6;
-  pyqt6SipStorePath = lib.getLib python312Packages.pyqt6-sip;
-  rapidfuzzStorePath = lib.getLib python312Packages.rapidfuzz;
-  qdarkstyleStorePath = lib.getLib python312Packages.qdarkstyle;
+  pypkgs = python313Packages;
+  qtpyStorePath = lib.getLib pypkgs.qtpy;
+  pyqt6StorePath = lib.getLib pypkgs.pyqt6;
+  pyqt6SipStorePath = lib.getLib pypkgs.pyqt6-sip;
+  rapidfuzzStorePath = lib.getLib pypkgs.rapidfuzz;
+  qdarkstyleStorePath = lib.getLib pypkgs.qdarkstyle;

  xorgLibX11StorePath = lib.getLib xorg.libX11;
  xorgLibxcbStorePath = lib.getLib xorg.libxcb;
@ -51,12 +52,12 @@ stdenv.mkDerivation {
    xorg.xcbutilrenderutil

    # Python requirements.
-    python312Full
-    python312Packages.uv
-    python312Packages.qdarkstyle
-    python312Packages.rapidfuzz
-    python312Packages.pyqt6
-    python312Packages.qtpy
+    python313
+    uv
+    pypkgs.qdarkstyle
+    pypkgs.rapidfuzz
+    pypkgs.pyqt6
+    pypkgs.qtpy
  ];
  src = null;
  shellHook = ''
@ -113,11 +114,11 @@ stdenv.mkDerivation {

    export LD_LIBRARY_PATH

-    RPDFUZZ_PATH="${rapidfuzzStorePath}/lib/python3.12/site-packages"
-    QDRKSTYLE_PATH="${qdarkstyleStorePath}/lib/python3.12/site-packages"
-    QTPY_PATH="${qtpyStorePath}/lib/python3.12/site-packages"
-    PYQT6_PATH="${pyqt6StorePath}/lib/python3.12/site-packages"
-    PYQT6_SIP_PATH="${pyqt6SipStorePath}/lib/python3.12/site-packages"
+    RPDFUZZ_PATH="${rapidfuzzStorePath}/lib/python3.13/site-packages"
+    QDRKSTYLE_PATH="${qdarkstyleStorePath}/lib/python3.13/site-packages"
+    QTPY_PATH="${qtpyStorePath}/lib/python3.13/site-packages"
+    PYQT6_PATH="${pyqt6StorePath}/lib/python3.13/site-packages"
+    PYQT6_SIP_PATH="${pyqt6SipStorePath}/lib/python3.13/site-packages"

    PATCH="$PATCH:$RPDFUZZ_PATH"
    PATCH="$PATCH:$QDRKSTYLE_PATH"
@ -127,8 +128,8 @@ stdenv.mkDerivation {

    export PATCH

-    # Install deps
-    uv lock
+    # install all dev and extras
+    uv sync --dev --all-extras

  '';
 }
--- a/examples/basic_order_bot.py
+++ b/examples/basic_order_bot.py
@ -121,6 +121,7 @@ async def bot_main():
            # tick_throttle=10,
        ) as feed,

+        tractor.trionics.collapse_eg(),
        trio.open_nursery() as tn,
    ):
        assert accounts
--- a/flake.lock
+++ b/flake.lock
@ -1,135 +1,24 @@
 {
  "nodes": {
-    "flake-utils": {
-      "inputs": {
-        "systems": "systems"
-      },
-      "locked": {
-        "lastModified": 1689068808,
-        "narHash": "sha256-6ixXo3wt24N/melDWjq70UuHQLxGV8jZvooRanIHXw0=",
-        "owner": "numtide",
-        "repo": "flake-utils",
-        "rev": "919d646de7be200f3bf08cb76ae1f09402b6f9b4",
-        "type": "github"
-      },
-      "original": {
-        "owner": "numtide",
-        "repo": "flake-utils",
-        "type": "github"
-      }
-    },
-    "flake-utils_2": {
-      "inputs": {
-        "systems": "systems_2"
-      },
-      "locked": {
-        "lastModified": 1689068808,
-        "narHash": "sha256-6ixXo3wt24N/melDWjq70UuHQLxGV8jZvooRanIHXw0=",
-        "owner": "numtide",
-        "repo": "flake-utils",
-        "rev": "919d646de7be200f3bf08cb76ae1f09402b6f9b4",
-        "type": "github"
-      },
-      "original": {
-        "owner": "numtide",
-        "repo": "flake-utils",
-        "type": "github"
-      }
-    },
-    "nix-github-actions": {
-      "inputs": {
-        "nixpkgs": [
-          "poetry2nix",
-          "nixpkgs"
-        ]
-      },
-      "locked": {
-        "lastModified": 1688870561,
-        "narHash": "sha256-4UYkifnPEw1nAzqqPOTL2MvWtm3sNGw1UTYTalkTcGY=",
-        "owner": "nix-community",
-        "repo": "nix-github-actions",
-        "rev": "165b1650b753316aa7f1787f3005a8d2da0f5301",
-        "type": "github"
-      },
-      "original": {
-        "owner": "nix-community",
-        "repo": "nix-github-actions",
-        "type": "github"
-      }
-    },
    "nixpkgs": {
      "locked": {
-        "lastModified": 1692174805,
-        "narHash": "sha256-xmNPFDi/AUMIxwgOH/IVom55Dks34u1g7sFKKebxUm0=",
-        "owner": "NixOS",
+        "lastModified": 1765779637,
+        "narHash": "sha256-KJ2wa/BLSrTqDjbfyNx70ov/HdgNBCBBSQP3BIzKnv4=",
+        "owner": "nixos",
        "repo": "nixpkgs",
-        "rev": "caac0eb6bdcad0b32cb2522e03e4002c8975c62e",
+        "rev": "1306659b587dc277866c7b69eb97e5f07864d8c4",
        "type": "github"
      },
      "original": {
-        "owner": "NixOS",
+        "owner": "nixos",
        "ref": "nixos-unstable",
        "repo": "nixpkgs",
        "type": "github"
      }
    },
-    "poetry2nix": {
-      "inputs": {
-        "flake-utils": "flake-utils_2",
-        "nix-github-actions": "nix-github-actions",
-        "nixpkgs": [
-          "nixpkgs"
-        ]
-      },
-      "locked": {
-        "lastModified": 1692048894,
-        "narHash": "sha256-cDw03rso2V4CDc3Mll0cHN+ztzysAvdI8pJ7ybbz714=",
-        "ref": "refs/heads/pyqt6",
-        "rev": "b059ad4c3051f45d6c912e17747aae37a9ec1544",
-        "revCount": 2276,
-        "type": "git",
-        "url": "file:///home/lord_fomo/repos/poetry2nix"
-      },
-      "original": {
-        "type": "git",
-        "url": "file:///home/lord_fomo/repos/poetry2nix"
-      }
-    },
    "root": {
      "inputs": {
-        "flake-utils": "flake-utils",
-        "nixpkgs": "nixpkgs",
-        "poetry2nix": "poetry2nix"
-      }
-    },
-    "systems": {
-      "locked": {
-        "lastModified": 1681028828,
-        "narHash": "sha256-Vy1rq5AaRuLzOxct8nz4T6wlgyUR7zLU309k9mBC768=",
-        "owner": "nix-systems",
-        "repo": "default",
-        "rev": "da67096a3b9bf56a91d16901293e51ba5b49a27e",
-        "type": "github"
-      },
-      "original": {
-        "owner": "nix-systems",
-        "repo": "default",
-        "type": "github"
-      }
-    },
-    "systems_2": {
-      "locked": {
-        "lastModified": 1681028828,
-        "narHash": "sha256-Vy1rq5AaRuLzOxct8nz4T6wlgyUR7zLU309k9mBC768=",
-        "owner": "nix-systems",
-        "repo": "default",
-        "rev": "da67096a3b9bf56a91d16901293e51ba5b49a27e",
-        "type": "github"
-      },
-      "original": {
-        "owner": "nix-systems",
-        "repo": "default",
-        "type": "github"
+        "nixpkgs": "nixpkgs"
      }
    }
  },
--- a/flake.nix
+++ b/flake.nix
@ -1,180 +1,103 @@
-# NOTE: to convert to a poetry2nix env like this here are the
-# steps:
-# - install poetry in your system nix config
-# - convert the repo to use poetry using `poetry init`:
-#   https://python-poetry.org/docs/basic-usage/#initialising-a-pre-existing-project
-# - then manually ensuring all deps are converted over:
-# - add this file to the repo and commit it
-# - 
-
-# GROKin tips:
-# - CLI eps are (ostensibly) added via an `entry_points.txt`:
-#   - https://packaging.python.org/en/latest/specifications/entry-points/#file-format
-#   - https://github.com/nix-community/poetry2nix/blob/master/editable.nix#L49
+# An "impure" template thx to `pyproject.nix`,
+# https://pyproject-nix.github.io/pyproject.nix/templates.html#impure
+# https://github.com/pyproject-nix/pyproject.nix/blob/master/templates/impure/flake.nix
 {
-  description = "piker: trading gear for hackers (pkged with poetry2nix)";
+  description = "An impure `piker` overlay using `uv` with Nix(OS)";

-  inputs.flake-utils.url = "github:numtide/flake-utils";
-  inputs.nixpkgs.url = "github:NixOS/nixpkgs/nixos-unstable";
-
-  # see https://github.com/nix-community/poetry2nix/tree/master#api
-  inputs.poetry2nix = {
-    # url = "github:nix-community/poetry2nix";
-    # url = "github:K900/poetry2nix/qt5-explicit-deps";
-    url = "/home/lord_fomo/repos/poetry2nix";
-
-    inputs.nixpkgs.follows = "nixpkgs";
+  inputs = {
+    nixpkgs.url = "github:nixos/nixpkgs/nixos-unstable";
  };

-  outputs = {
-    self,
-    nixpkgs,
-    flake-utils,
-    poetry2nix,
-  }:
-    # TODO: build cross-OS and use the `${system}` var thingy..
-    flake-utils.lib.eachDefaultSystem (system:
-      let
-        # use PWD as sources
-        projectDir = ./.;
-        pyproject = ./pyproject.toml;
-        poetrylock = ./poetry.lock;
+  outputs =
+    { nixpkgs, ... }:
+    let
+      inherit (nixpkgs) lib;
+      forAllSystems = lib.genAttrs lib.systems.flakeExposed;
+    in
+    {
+      devShells = forAllSystems (
+        system:
+        let
+          pkgs = nixpkgs.legacyPackages.${system};

-        # TODO: port to 3.11 and support both versions?
-        python = "python3.10";
+          # do store-path extractions
+          qt6baseStorePath = lib.getLib pkgs.qt6.qtbase;
+          # ?TODO? can remove below since manual linking not needed?
+          # qt6QtWaylandStorePath = lib.getLib pkgs.qt6.qtwayland;

-        # for more functions and examples.
-        # inherit
-        # (poetry2nix.legacyPackages.${system})
-        # mkPoetryApplication;
-        # pkgs = nixpkgs.legacyPackages.${system};
+          # XXX NOTE XXX, for now we overlay specific pkgs via
+          # a major-version-pinned-`cpython`
+          cpython = "python313";
+          pypkgs = pkgs."${cpython}Packages";
+        in
+        {
+          default = pkgs.mkShell {

-        pkgs = nixpkgs.legacyPackages.x86_64-linux;
-        lib = pkgs.lib;
-        p2npkgs = poetry2nix.legacyPackages.x86_64-linux;
+            packages = with pkgs; [
+              # XXX, ensure sh completions active!
+              bashInteractive
+              bash-completion

-        # define all pkg overrides per dep, see edgecases.md:
-        # https://github.com/nix-community/poetry2nix/blob/master/docs/edgecases.md
-        # TODO: add these into the json file:
-        # https://github.com/nix-community/poetry2nix/blob/master/overrides/build-systems.json
-        pypkgs-build-requirements = {
-          asyncvnc = [ "setuptools" ];
-          eventkit = [ "setuptools" ];
-          ib-insync = [ "setuptools" "flake8" ];
-          msgspec = [ "setuptools"];
-          pdbp = [ "setuptools" ];
-          pyqt6-sip = [ "setuptools" ];
-          tabcompleter = [ "setuptools" ];
-          tractor = [ "setuptools" ];
-          tricycle = [ "setuptools" ];
-          trio-typing = [ "setuptools" ];
-          trio-util = [ "setuptools" ];
-          xonsh = [ "setuptools" ];
-        };
+              # dev utils
+              ruff
+              pypkgs.ruff

-        # auto-generate override entries
-        p2n-overrides = p2npkgs.defaultPoetryOverrides.extend (self: super:
-          builtins.mapAttrs (package: build-requirements:
-            (builtins.getAttr package super).overridePythonAttrs (old: {
-              buildInputs = (
-                old.buildInputs or [ ]
-              ) ++ (
-                builtins.map (
-                  pkg: if builtins.isString pkg then builtins.getAttr pkg super else pkg
-                  ) build-requirements
-              );
-            })
-          ) pypkgs-build-requirements
-        );
+              qt6.qtwayland
+              qt6.qtbase

-        # override some ahead-of-time compiled extensions
-        # to be built with their wheels.
-        ahot_overrides = p2n-overrides.extend(
-          final: prev: {
+              uv
+              python313  # ?TODO^ how to set from `cpython` above?
+              pypkgs.pyqt6
+              pypkgs.pyqt6-sip
+              pypkgs.qtpy
+              pypkgs.qdarkstyle
+              pypkgs.rapidfuzz
+            ];

-            # llvmlite = prev.llvmlite.override {
-            #   preferWheel = false;
-            # };
+            shellHook = ''
+              # unmask to debug **this** dev-shell-hook
+              # set -e

-            # TODO: get this workin with p2n and nixpkgs..
-            # pyqt6 = prev.pyqt6.override {
-            #   preferWheel = true;
-            # };
+              # set qt-base/plugin path(s)
+              QTBASE_PATH="${qt6baseStorePath}/lib"
+              QT_PLUGIN_PATH="${qt6baseStorePath}/lib/qt-6/plugins"
+              QT_QPA_PLATFORM_PLUGIN_PATH="$QT_PLUGIN_PATH/platforms"

-            # NOTE: this DOESN'T work atm but after a fix
-            # to poetry2nix, it will and actually this line
-            # won't be needed - thanks @k900:
-            # https://github.com/nix-community/poetry2nix/pull/1257
-            pyqt5 = prev.pyqt5.override {
-              # withWebkit = false;
-              preferWheel = true;
-            };
+              # link in Qt cc lib paths from <nixpkgs>
+              LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QTBASE_PATH"
+              LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QT_PLUGIN_PATH"
+              LD_LIBRARY_PATH="$LD_LIBRARY_PATH:$QT_QPA_PLATFORM_PLUGIN_PATH"

-            # see PR from @k900:
-            # https://github.com/nix-community/poetry2nix/pull/1257
-            # pyqt5-qt5 = prev.pyqt5-qt5.override {
-            #   withWebkit = false;
-            #   preferWheel = true;
-            # };
+              # link-in c++ stdlib for various AOT-ext-pkgs (numpy, etc.)
+              LD_LIBRARY_PATH="${pkgs.stdenv.cc.cc.lib}/lib:$LD_LIBRARY_PATH"

-            # TODO: patch in an override for polars to build
-            # from src! See the details likely needed from
-            # the cryptography entry:
-            # https://github.com/nix-community/poetry2nix/blob/master/overrides/default.nix#L426-L435
-            polars = prev.polars.override {
-              preferWheel = true;
-            };
-          }
-      );
+              export LD_LIBRARY_PATH

-      # WHY!? -> output-attrs that `nix develop` scans for:
-      # https://nixos.org/manual/nix/stable/command-ref/new-cli/nix3-develop.html#flake-output-attributes
-      in
-      rec {
-        packages = {
-          # piker = poetry2nix.legacyPackages.x86_64-linux.mkPoetryEditablePackage {
-          #   editablePackageSources = { piker = ./piker; };
+              # RUNTIME-SETTINGS
+              #
+              # ------ Qt ------
+              # XXX, unmask to debug qt .so linking/loading deats
+              # export QT_DEBUG_PLUGINS=1
+              #
+              # ALSO, for *modern linux* DEs,
+              # - maybe set wayland-mode (TODO, parametrtize this!)
+              #  * a chosen wayland-mode shell-integration
+              export QT_QPA_PLATFORM="wayland"
+              export QT_WAYLAND_SHELL_INTEGRATION="xdg-shell"

-          piker = p2npkgs.mkPoetryApplication {
-            projectDir = projectDir;
+              # ------ uv ------
+              # - always use the ./py313/ venv-subdir
+              export UV_PROJECT_ENVIRONMENT="py313"
+              # sync project-env with all extras
+              uv sync --dev --all-extras --no-group lint

-            # SEE ABOVE for auto-genned input set, override
-            # buncha deps with extras.. like `setuptools` mostly.
-            # TODO: maybe propose a patch to p2n to show that you
-            # can even do this in the edgecases docs?
-            overrides = ahot_overrides;
-
-            # XXX: won't work on llvmlite..
-            # preferWheels = true;
+              # ------ TIPS ------
+              # NOTE, to launch the py-venv installed `xonsh` (like @goodboy)
+              # run the `nix develop` cmd with,
+              # >> nix develop -c uv run xonsh
+            '';
          };
-        };
-
-        # devShells.default = pkgs.mkShell {
-        #   projectDir = projectDir;
-        #   python = "python3.10";
-        #   overrides = ahot_overrides;
-        #   inputsFrom = [ self.packages.x86_64-linux.piker ];
-        #   packages = packages;
-        #   # packages = [ poetry2nix.packages.${system}.poetry ];
-        # };
-
-        # TODO: grok the difference here..
-        # - avoid re-cloning git repos on every develop entry..
-        # - ideally allow hacking on the src code of some deps
-        #   (tractor, pyqtgraph, tomlkit, etc.) WITHOUT having to
-        #   re-install them every time a change is made.
-        # - boot a usable xonsh inside the poetry virtualenv when
-        #   defined via a custom entry point?
-        devShells.default = p2npkgs.mkPoetryEnv {
-        # env = p2npkgs.mkPoetryEnv {
-            projectDir = projectDir;
-            python = pkgs.python310;
-            overrides = ahot_overrides;
-            editablePackageSources = packages;
-              # piker = "./";
-              # tractor = "../tractor/";
-            # };  # wut?
-        };
-      }
-    );  # end of .outputs scope
+        }
+      );
+    };
 }
--- a/notes_to_self/ideas.rst
+++ b/notes_to_self/ideas.rst
--- a/piker/accounting/init.py
+++ b/piker/accounting/init.py
@ -42,7 +42,6 @@ from ._mktinfo import (
    dec_digits,
    digits_to_dec,
    MktPair,
-    Symbol,
    unpack_fqme,
    _derivs as DerivTypes,
 )
@ -60,7 +59,6 @@ __all__ = [
    'Asset',
    'MktPair',
    'Position',
-    'Symbol',
    'Transaction',
    'TransactionLedger',
    'dec_digits',
--- a/piker/accounting/_ledger.py
+++ b/piker/accounting/_ledger.py
@ -40,7 +40,7 @@ import tomli_w  # for fast ledger writing

 from piker.types import Struct
 from piker import config
-from ..log import get_logger
+from piker.log import get_logger
 from .calc import (
    iter_by_dt,
 )
@ -239,7 +239,9 @@ class TransactionLedger(UserDict):

        symcache: SymbologyCache = self._symcache
        towrite: dict[str, Any] = {}
-        for tid, txdict in self.tx_sort(self.data.copy()):
+        for tid, txdict in self.tx_sort(
+            self.data.copy()
+        ):
            # write blank-str expiry for non-expiring assets
            if (
                'expiry' in txdict
@ -377,7 +379,7 @@ def open_trade_ledger(
        account,
        dirpath=_fp,
    )
-    cpy = ledger_dict.copy()
+    cpy: dict = ledger_dict.copy()

    # XXX NOTE: if not provided presume we are being called from
    # sync code and need to maybe run `trio` to generate..
@ -406,7 +408,13 @@ def open_trade_ledger(
        account=account,
        mod=mod,
        symcache=symcache,
-        tx_sort=getattr(mod, 'tx_sort', tx_sort),
+
+        # NOTE: allow backends to provide custom ledger sorting
+        tx_sort=getattr(
+            mod,
+            'tx_sort',
+            tx_sort,
+        ),
    )
    try:
        yield ledger
--- a/piker/accounting/_mktinfo.py
+++ b/piker/accounting/_mktinfo.py
@ -305,8 +305,8 @@ class MktPair(Struct, frozen=True):
    # config right?
    # src_type: AssetTypeName

-    # for derivs, info describing contract, egs.
-    # strike price, call or put, swap type, exercise model, etc.
+    # for derivs, info describing contract, egs. strike price, call
+    # or put, swap type, exercise model, etc.
    contract_info: list[str] | None = None

    # TODO: rename to sectype since all of these can
@ -390,8 +390,8 @@ class MktPair(Struct, frozen=True):
        cls,
        fqme: str,

-        price_tick: float | str,
-        size_tick: float | str,
+        price_tick: float|str,
+        size_tick: float|str,
        bs_mktid: str,

        broker: str | None = None,
@ -677,90 +677,3 @@ def unpack_fqme(
        # '.'.join([mkt_ep, venue]),
        suffix,
    )
-
-
-class Symbol(Struct):
-    '''
-    I guess this is some kinda container thing for dealing with
-    all the different meta-data formats from brokers?
-
-    '''
-    key: str
-
-    broker: str = ''
-    venue: str = ''
-
-    # precision descriptors for price and vlm
-    tick_size: Decimal = Decimal('0.01')
-    lot_tick_size: Decimal = Decimal('0.0')
-
-    suffix: str = ''
-    broker_info: dict[str, dict[str, Any]] = {}
-
-    @classmethod
-    def from_fqme(
-        cls,
-        fqsn: str,
-        info: dict[str, Any],
-
-    ) -> Symbol:
-        broker, mktep, venue, suffix = unpack_fqme(fqsn)
-        tick_size = info.get('price_tick_size', 0.01)
-        lot_size = info.get('lot_tick_size', 0.0)
-
-        return Symbol(
-            broker=broker,
-            key=mktep,
-            tick_size=tick_size,
-            lot_tick_size=lot_size,
-            venue=venue,
-            suffix=suffix,
-            broker_info={broker: info},
-        )
-
-    @property
-    def type_key(self) -> str:
-        return list(self.broker_info.values())[0]['asset_type']
-
-    @property
-    def tick_size_digits(self) -> int:
-        return float_digits(self.tick_size)
-
-    @property
-    def lot_size_digits(self) -> int:
-        return float_digits(self.lot_tick_size)
-
-    @property
-    def price_tick(self) -> Decimal:
-        return Decimal(str(self.tick_size))
-
-    @property
-    def size_tick(self) -> Decimal:
-        return Decimal(str(self.lot_tick_size))
-
-    @property
-    def broker(self) -> str:
-        return list(self.broker_info.keys())[0]
-
-    @property
-    def fqme(self) -> str:
-        return maybe_cons_tokens([
-            self.key,  # final "pair name" (eg. qqq[/usd], btcusdt)
-            self.venue,
-            self.suffix,  # includes expiry and other con info
-            self.broker,
-        ])
-
-    def quantize(
-        self,
-        size: float,
-    ) -> Decimal:
-        digits = float_digits(self.lot_tick_size)
-        return Decimal(size).quantize(
-            Decimal(f'1.{"0".ljust(digits, "0")}'),
-            rounding=ROUND_HALF_EVEN
-        )
-
-    # NOTE: when cast to `str` return fqme
-    def __str__(self) -> str:
-        return self.fqme
--- a/piker/accounting/_pos.py
+++ b/piker/accounting/_pos.py
@ -30,7 +30,8 @@ from types import ModuleType
 from typing import (
    Any,
    Iterator,
-    Generator
+    Generator,
+    TYPE_CHECKING,
 )

 import pendulum
@ -59,8 +60,10 @@ from ..clearing._messages import (
    BrokerdPosition,
 )
 from piker.types import Struct
-from piker.data._symcache import SymbologyCache
-from ..log import get_logger
+from piker.log import get_logger
+
+if TYPE_CHECKING:
+    from piker.data._symcache import SymbologyCache

 log = get_logger(__name__)

@ -362,7 +365,11 @@ class Position(Struct):
        # added: bool = False
        tid: str = t.tid
        if tid in self._events:
-            log.warning(f'{t} is already added?!')
+            log.debug(
+                f'Txn is already added?\n'
+                f'\n'
+                f'{t}\n'
+            )
            # return added

        # TODO: apparently this IS possible with a dict but not
@ -493,6 +500,17 @@ class Account(Struct):

        _mktmap_table: dict[str, MktPair] | None = None,

+        only_require: list[str]|True = True,
+        # ^list of fqmes that are "required" to be processed from
+        # this ledger pass; we often don't care about others and
+        # definitely shouldn't always error in such cases.
+        # (eg. broker backend loaded that doesn't yet supsport the
+        # symcache but also, inside the paper engine we don't ad-hoc
+        # request `get_mkt_info()` for every symbol in the ledger,
+        # only the one for which we're simulating against).
+        # TODO, not sure if there's a better soln for this, ideally
+        # all backends get symcache support afap i guess..
+
    ) -> dict[str, Position]:
        '''
        Update the internal `.pps[str, Position]` table from input
@ -535,11 +553,32 @@ class Account(Struct):
                if _mktmap_table is None:
                    raise

+                required: bool = (
+                    only_require is True
+                    or (
+                        only_require is not True
+                        and
+                        fqme in only_require
+                    )
+                )
                # XXX: caller is allowed to provide a fallback
                # mktmap table for the case where a new position is
                # being added and the preloaded symcache didn't
                # have this entry prior (eg. with frickin IB..)
-                mkt = _mktmap_table[fqme]
+                if (
+                    not (mkt := _mktmap_table.get(fqme))
+                    and
+                    required
+                ):
+                    raise
+
+                elif not required:
+                    continue
+
+                else:
+                    # should be an entry retreived somewhere
+                    assert mkt
+

            if not (pos := pps.get(bs_mktid)):

@ -656,7 +695,7 @@ class Account(Struct):
    def write_config(self) -> None:
        '''
        Write the current account state to the user's account TOML file, normally
-        something like ``pps.toml``.
+        something like `pps.toml`.

        '''
        # TODO: show diff output?
@ -696,7 +735,7 @@ class Account(Struct):
                    else:
                        # TODO: we reallly need a diff set of
                        # loglevels/colors per subsys.
-                        log.warning(
+                        log.debug(
                            f'Recent position for {fqme} was closed!'
                        )

--- a/piker/accounting/calc.py
+++ b/piker/accounting/calc.py
@ -22,7 +22,9 @@ you know when you're losing money (if possible) XD
 from __future__ import annotations
 from collections.abc import ValuesView
 from contextlib import contextmanager as cm
+from functools import partial
 from math import copysign
+from pprint import pformat
 from typing import (
    Any,
    Callable,
@ -37,12 +39,16 @@ from pendulum import (
    parse,
 )

+from ..log import get_logger
+
 if TYPE_CHECKING:
    from ._ledger import (
        Transaction,
        TransactionLedger,
    )

+log = get_logger(__name__)
+

 def ppu(
    clears: Iterator[Transaction],
@ -238,6 +244,9 @@ def iter_by_dt(

    def dyn_parse_to_dt(
        tx: tuple[str, dict[str, Any]] | Transaction,
+
+        debug: bool = False,
+        _invalid: list|None = None,
    ) -> DateTime:

        # handle `.items()` inputs
@ -250,33 +259,81 @@ def iter_by_dt(
        # get best parser for this record..
        for k in parsers:
            if (
-                isdict and k in tx
-                 or getattr(tx, k, None)
+                (v := getattr(tx, k, None))
+                or
+                (
+                    isdict
+                    and
+                    (v := tx.get(k))
+                )
            ):
-                v = tx[k] if isdict else tx.dt
-                assert v is not None, f'No valid value for `{k}`!?'
-
                # only call parser on the value if not None from
                # the `parsers` table above (when NOT using
                # `.get()`), otherwise pass through the value and
                # sort on it directly
                if (
                    not isinstance(v, DateTime)
-                    and (parser := parsers.get(k))
+                    and
+                    (parser := parsers.get(k))
                ):
-                    return parser(v)
+                    ret = parser(v)
                else:
-                    return v
+                    ret = v

+                return ret
+
+            else:
+                log.debug(
+                    f'Parser-field not found in txn\n'
+                    f'\n'
+                    f'parser-field: {k!r}\n'
+                    f'txn: {tx!r}\n'
+                    f'\n'
+                    f'Trying next..\n'
+                )
+                continue
+
+        # XXX: should never get here..
        else:
-            # XXX: should never get here..
-            breakpoint()
+            # XXX: we should really never get here..
+            # only if a ledger record has no expected sort(able)
+            # field will we likely hit this.. like with ze IB.
+            # if no sortable field just deliver epoch?
+            log.warning(
+                'No (time) sortable field for TXN:\n'
+                f'{tx!r}\n'
+            )
+            if debug:
+                import tractor
+                with tractor.devx.maybe_open_crash_handler():
+                    raise ValueError(
+                        f'No supported time-field found in txn !?\n'
+                        f'\n'
+                        f'supported-time-fields: {parsers!r}\n'
+                        f'\n'
+                        f'txn: {tx!r}\n'
+                    )

-    entry: tuple[str, dict] | Transaction
+            if _invalid is not None:
+                _invalid.append(tx)
+                return from_timestamp(0.)
+
+    entry: tuple[str, dict]|Transaction
+    invalid: list = []
    for entry in sorted(
        records,
-        key=key or dyn_parse_to_dt,
+        key=key or partial(
+            dyn_parse_to_dt,
+            _invalid=invalid,
+        ),
    ):
+        if entry in invalid:
+            log.warning(
+                f'Ignoring txn w invalid timestamp ??\n'
+                f'{pformat(entry)}\n'
+            )
+            continue
+
        # NOTE the type sig above; either pairs or txns B)
        yield entry

--- a/piker/accounting/cli.py
+++ b/piker/accounting/cli.py
@ -300,7 +300,8 @@ def disect(
        assert not df.is_empty()

        # muck around in pdbp REPL
-        breakpoint()
+        # tractor.devx.mk_pdb().set_trace()
+        # breakpoint()

        # TODO: we REALLY need a better console REPL for this
        # kinda thing..
--- a/piker/brokers/init.py
+++ b/piker/brokers/init.py
@ -98,13 +98,14 @@ async def open_cached_client(
    If one has not been setup do it and cache it.

    '''
-    brokermod = get_brokermod(brokername)
+    brokermod: ModuleType = get_brokermod(brokername)
+
+    # TODO: make abstract or `typing.Protocol`
+    # client: Client
    async with maybe_open_context(
        acm_func=brokermod.get_client,
        kwargs=kwargs,
-
    ) as (cache_hit, client):
-
        if cache_hit:
            log.runtime(f'Reusing existing {client}')

--- a/piker/brokers/_daemon.py
+++ b/piker/brokers/_daemon.py
@ -96,7 +96,10 @@ async def _setup_persistent_brokerd(
    # - `open_symbol_search()`
    # NOTE: see ep invocation details inside `.data.feed`.
    try:
-        async with trio.open_nursery() as service_nursery:
+        async with (
+            tractor.trionics.collapse_eg(),
+            trio.open_nursery() as service_nursery
+        ):
            bus: _FeedsBus = feed.get_feed_bus(
                brokername,
                service_nursery,
--- a/piker/brokers/binance/api.py
+++ b/piker/brokers/binance/api.py
@ -374,9 +374,14 @@ class Client:
                pair: Pair = pair_type(**item)
            except Exception as e:
                e.add_note(
-                    "\nDon't panic, prolly stupid binance changed their symbology schema again..\n"
-                    'Check out their API docs here:\n\n'
-                    'https://binance-docs.github.io/apidocs/spot/en/#exchange-information'
+                    f'\n'
+                    f'New or removed field we need to codify!\n'
+                    f'pair-type: {pair_type!r}\n'
+                    f'\n'
+                    f"Don't panic, prolly stupid binance changed their symbology schema again..\n"
+                    f'Check out their API docs here:\n'
+                    f'\n'
+                    f'https://binance-docs.github.io/apidocs/spot/en/#exchange-information\n'
                )
                raise
            pair_table[pair.symbol.upper()] = pair
--- a/piker/brokers/binance/broker.py
+++ b/piker/brokers/binance/broker.py
@ -440,6 +440,7 @@ async def open_trade_dialog(
            #   - ledger: TransactionLedger

            async with (
+                tractor.trionics.collapse_eg(),
                trio.open_nursery() as tn,
                ctx.open_stream() as ems_stream,
            ):
--- a/piker/brokers/binance/venues.py
+++ b/piker/brokers/binance/venues.py
@ -97,6 +97,13 @@ class Pair(Struct, frozen=True, kw_only=True):
    baseAsset: str
    baseAssetPrecision: int

+    permissionSets: list[list[str]]
+
+    # https://developers.binance.com/docs/binance-spot-api-docs#2025-08-26
+    # will become non-optional 2025-08-28?
+    # https://developers.binance.com/docs/binance-spot-api-docs#future-changes
+    pegInstructionsAllowed: bool|None = None
+
    filters: dict[
        str,
        str | int | float,
@ -142,7 +149,11 @@ class SpotPair(Pair, frozen=True):
    defaultSelfTradePreventionMode: str
    allowedSelfTradePreventionModes: list[str]
    permissions: list[str]
-    permissionSets: list[list[str]]
+
+    # can the paint botz creat liq gaps even easier on this asset?
+    # Bp
+    # https://developers.binance.com/docs/binance-spot-api-docs/faqs/order_amend_keep_priority
+    amendAllowed: bool

    # NOTE: see `.data._symcache.SymbologyCache.load()` for why
    ns_path: str = 'piker.brokers.binance:SpotPair'
--- a/piker/brokers/cli.py
+++ b/piker/brokers/cli.py
@ -471,11 +471,15 @@ def search(

    '''
    # global opts
-    brokermods = list(config['brokermods'].values())
+    brokermods: list[ModuleType] = list(config['brokermods'].values())
+
+    # TODO: this is coming from the `search --pdb` NOT from
+    # the `piker --pdb` XD ..
+    # -[ ] pull from the parent click ctx's values..dumdum
+    # assert pdb

    # define tractor entrypoint
    async def main(func):
-
        async with maybe_open_pikerd(
            loglevel=config['loglevel'],
            debug_mode=pdb,
--- a/piker/brokers/core.py
+++ b/piker/brokers/core.py
@ -22,7 +22,9 @@ routines should be primitive data types where possible.
 """
 import inspect
 from types import ModuleType
-from typing import List, Dict, Any, Optional
+from typing import (
+    Any,
+)

 import trio

@ -34,8 +36,10 @@ from ..accounting import MktPair


 async def api(brokername: str, methname: str, **kwargs) -> dict:
-    """Make (proxy through) a broker API call by name and return its result.
-    """
+    '''
+    Make (proxy through) a broker API call by name and return its result.
+
+    '''
    brokermod = get_brokermod(brokername)
    async with brokermod.get_client() as client:
        meth = getattr(client, methname, None)
@ -62,10 +66,14 @@ async def api(brokername: str, methname: str, **kwargs) -> dict:

 async def stocks_quote(
    brokermod: ModuleType,
-    tickers: List[str]
-) -> Dict[str, Dict[str, Any]]:
-    """Return quotes dict for ``tickers``.
-    """
+    tickers: list[str]
+
+) -> dict[str, dict[str, Any]]:
+    '''
+    Return a `dict` of snapshot quotes for the provided input
+    `tickers`: a `list` of fqmes.
+
+    '''
    async with brokermod.get_client() as client:
        return await client.quote(tickers)

@ -74,13 +82,15 @@ async def stocks_quote(
 async def option_chain(
    brokermod: ModuleType,
    symbol: str,
-    date: Optional[str] = None,
-) -> Dict[str, Dict[str, Dict[str, Any]]]:
-    """Return option chain for ``symbol`` for ``date``.
+    date: str|None = None,
+) -> dict[str, dict[str, dict[str, Any]]]:
+    '''
+    Return option chain for ``symbol`` for ``date``.

    By default all expiries are returned. If ``date`` is provided
    then contract quotes for that single expiry are returned.
-    """
+
+    '''
    async with brokermod.get_client() as client:
        if date:
            id = int((await client.tickers2ids([symbol]))[symbol])
@ -98,7 +108,7 @@ async def option_chain(
 # async def contracts(
 #     brokermod: ModuleType,
 #     symbol: str,
-# ) -> Dict[str, Dict[str, Dict[str, Any]]]:
+# ) -> dict[str, dict[str, dict[str, Any]]]:
 #     """Return option contracts (all expiries) for ``symbol``.
 #     """
 #     async with brokermod.get_client() as client:
@ -110,15 +120,24 @@ async def bars(
    brokermod: ModuleType,
    symbol: str,
    **kwargs,
-) -> Dict[str, Dict[str, Dict[str, Any]]]:
-    """Return option contracts (all expiries) for ``symbol``.
-    """
+) -> dict[str, dict[str, dict[str, Any]]]:
+    '''
+    Return option contracts (all expiries) for ``symbol``.
+
+    '''
    async with brokermod.get_client() as client:
        return await client.bars(symbol, **kwargs)


-async def search_w_brokerd(name: str, pattern: str) -> dict:
+async def search_w_brokerd(
+    name: str,
+    pattern: str,
+) -> dict:

+    # TODO: WHY NOT WORK!?!
+    # when we `step` through the next block?
+    # import tractor
+    # await tractor.pause()
    async with open_cached_client(name) as client:

        # TODO: support multiple asset type concurrent searches.
@ -130,12 +149,12 @@ async def symbol_search(
    pattern: str,
    **kwargs,

-) -> Dict[str, Dict[str, Dict[str, Any]]]:
+) -> dict[str, dict[str, dict[str, Any]]]:
    '''
    Return symbol info from broker.

    '''
-    results = []
+    results: list[str] = []

    async def search_backend(
        brokermod: ModuleType
@ -143,6 +162,13 @@ async def symbol_search(

        brokername: str = mod.name

+        # TODO: figure this the FUCK OUT
+        # -> ok so obvi in the root actor any async task that's
+        # spawned outside the main tractor-root-actor task needs to
+        # call this..
+        # await tractor.devx._debug.maybe_init_greenback()
+        # tractor.pause_from_sync()
+
        async with maybe_spawn_brokerd(
            mod.name,
            infect_asyncio=getattr(
@ -162,7 +188,6 @@ async def symbol_search(
            ))

    async with trio.open_nursery() as n:
-
        for mod in brokermods:
            n.start_soon(search_backend, mod.name)

@ -172,11 +197,13 @@ async def symbol_search(
 async def mkt_info(
    brokermod: ModuleType,
    fqme: str,
+
    **kwargs,

 ) -> MktPair:
    '''
-    Return MktPair info from broker including src and dst assets.
+    Return the `piker.accounting.MktPair` info struct from a given
+    backend broker tradable src/dst asset pair.

    '''
    async with open_cached_client(brokermod.name) as client:
--- a/piker/brokers/deribit/api.py
+++ b/piker/brokers/deribit/api.py
@ -31,7 +31,7 @@ from typing import (
    Callable,
 )

-import pendulum
+from pendulum import now
 import trio
 from trio_typing import TaskStatus
 from rapidfuzz import process as fuzzy
@ -39,6 +39,7 @@ import numpy as np
 from tractor.trionics import (
    broadcast_receiver,
    maybe_open_context
+    collapse_eg,
 )
 from tractor import to_asyncio
 # XXX WOOPS XD
@ -432,6 +433,7 @@ async def get_client(
 ) -> Client:

    async with (
+        collapse_eg(),
        trio.open_nursery() as n,
        open_jsonrpc_session(
            _testnet_ws_url, dtype=JSONRPCResult) as json_rpc
--- a/piker/brokers/ib/_util.py
+++ b/piker/brokers/ib/_util.py
@ -34,6 +34,7 @@ from piker.brokers._util import get_logger
 if TYPE_CHECKING:
    from .api import Client
    from ib_insync import IB
+    import i3ipc

 log = get_logger('piker.brokers.ib')

@ -48,6 +49,37 @@ _reset_tech: Literal[
 ] = 'vnc'


+no_setup_msg:str = (
+    'No data reset hack test setup for {vnc_sockaddr}!\n'
+    'See config setup tips @\n'
+    'https://github.com/pikers/piker/tree/master/piker/brokers/ib'
+)
+
+
+def try_xdo_manual(
+    vnc_sockaddr: str,
+):
+    '''
+    Do the "manual" `xdo`-based screen switch + click
+    combo since apparently the `asyncvnc` client ain't workin..
+
+    Note this is only meant as a backup method for Xorg users,
+    ideally you can use a real vnc client and the `vnc_click_hack()`
+    impl!
+
+    '''
+    global _reset_tech
+    try:
+        i3ipc_xdotool_manual_click_hack()
+        _reset_tech = 'i3ipc_xdotool'
+        return True
+    except OSError:
+        log.exception(
+            no_setup_msg.format(vnc_sockaddr)
+        )
+        return False
+
+
 async def data_reset_hack(
    # vnc_host: str,
    client: Client,
@ -90,15 +122,9 @@ async def data_reset_hack(
    vnc_port: int
    vnc_sockaddr: tuple[str] | None = client.conf.get('vnc_addrs')

-    no_setup_msg:str = (
-        f'No data reset hack test setup for {vnc_sockaddr}!\n'
-        'See config setup tips @\n'
-        'https://github.com/pikers/piker/tree/master/piker/brokers/ib'
-    )
-
    if not vnc_sockaddr:
        log.warning(
-            no_setup_msg
+            no_setup_msg.format(vnc_sockaddr)
            +
            'REQUIRES A `vnc_addrs: array` ENTRY'
        )
@ -119,27 +145,38 @@ async def data_reset_hack(
                        port=vnc_port,
                    )
                )
-            except OSError:
-                if vnc_host != 'localhost':
-                    log.warning(no_setup_msg)
-                    return False
-
+            except (
+                OSError,  # no VNC server avail..
+                PermissionError,  # asyncvnc pw fail..
+            ):
                try:
                    import i3ipc  # noqa  (since a deps dynamic check)
                except ModuleNotFoundError:
-                    log.warning(no_setup_msg)
+                    log.warning(
+                        no_setup_msg.format(vnc_sockaddr)
+                    )
                    return False

-                try:
-                    i3ipc_xdotool_manual_click_hack()
-                    _reset_tech = 'i3ipc_xdotool'
-                    return True
-                except OSError:
-                    log.exception(no_setup_msg)
-                    return False
+                if vnc_host not in {
+                    'localhost',
+                    '127.0.0.1',
+                }:
+                    focussed, matches = i3ipc_fin_wins_titled()
+                    if not matches:
+                        log.warning(
+                            no_setup_msg.format(vnc_sockaddr)
+                        )
+                        return False
+                    else:
+                        try_xdo_manual(vnc_sockaddr)
+
+                # localhost but no vnc-client or it borked..
+                else:
+                    try_xdo_manual(vnc_sockaddr)

        case 'i3ipc_xdotool':
-            i3ipc_xdotool_manual_click_hack()
+            try_xdo_manual(vnc_sockaddr)
+            # i3ipc_xdotool_manual_click_hack()

        case _ as tech:
            raise RuntimeError(f'{tech} is not supported for reset tech!?')
@ -178,9 +215,9 @@ async def vnc_click_hack(
        host,
        port=port,

-        # TODO: doesn't work see:
-        # https://github.com/barneygale/asyncvnc/issues/7
-        # password='ibcansmbz',
+        # TODO: doesn't work?
+        # see, https://github.com/barneygale/asyncvnc/issues/7
+        password='doggy',

    ) as client:

@ -194,70 +231,103 @@ async def vnc_click_hack(
        client.keyboard.press('Ctrl', 'Alt', key)  # keys are stacked


+def i3ipc_fin_wins_titled(
+    titles: list[str] = [
+        'Interactive Brokers',  # tws running in i3
+        'IB Gateway',  # gw running in i3
+        # 'IB',  # gw running in i3 (newer version?)
+
+        # !TODO, remote vnc instance
+        # -[ ] something in title (or other Con-props) that indicates
+        #   this is explicitly for ibrk sw?
+        #  |_[ ]  !can use modden spawn eventually!
+        'TigerVNC',
+        # 'vncviewer',  # the terminal..
+    ],
+) -> tuple[
+    i3ipc.Con,  # orig focussed win
+    list[tuple[str, i3ipc.Con]],  # matching wins by title
+]:
+    '''
+    Attempt to find a local-DE window titled with an entry in
+    `titles`.
+
+    If found deliver the current focussed window and all matching
+    `i3ipc.Con`s in a list.
+
+    '''
+    import i3ipc
+    ipc = i3ipc.Connection()
+
+    # TODO: might be worth offering some kinda api for grabbing
+    # the window id from the pid?
+    # https://stackoverflow.com/a/2250879
+    tree = ipc.get_tree()
+    focussed: i3ipc.Con = tree.find_focused()
+
+    matches: list[i3ipc.Con] = []
+    for name in titles:
+        results = tree.find_titled(name)
+        print(f'results for {name}: {results}')
+        if results:
+            con = results[0]
+            matches.append((
+                name,
+                con,
+            ))
+
+    return (
+        focussed,
+        matches,
+    )
+
+
+
 def i3ipc_xdotool_manual_click_hack() -> None:
    '''
    Do the data reset hack but expecting a local X-window using `xdotool`.

    '''
-    import i3ipc
-    i3 = i3ipc.Connection()
-
-    # TODO: might be worth offering some kinda api for grabbing
-    # the window id from the pid?
-    # https://stackoverflow.com/a/2250879
-    t = i3.get_tree()
-
-    orig_win_id = t.find_focused().window
-
-    # for tws
-    win_names: list[str] = [
-        'Interactive Brokers',  # tws running in i3
-        'IB Gateway',  # gw running in i3
-        # 'IB',  # gw running in i3 (newer version?)
-    ]
-
+    focussed, matches = i3ipc_fin_wins_titled()
+    orig_win_id = focussed.window
    try:
-        for name in win_names:
-            results = t.find_titled(name)
-            print(f'results for {name}: {results}')
-            if results:
-                con = results[0]
-                print(f'Resetting data feed for {name}')
-                win_id = str(con.window)
-                w, h = con.rect.width, con.rect.height
+        for name, con in matches:
+            print(f'Resetting data feed for {name}')
+            win_id = str(con.window)
+            w, h = con.rect.width, con.rect.height

-                # TODO: seems to be a few libs for python but not sure
-                # if they support all the sub commands we need, order of
-                # most recent commit history:
-                # https://github.com/rr-/pyxdotool
-                # https://github.com/ShaneHutter/pyxdotool
-                # https://github.com/cphyc/pyxdotool
+            # TODO: seems to be a few libs for python but not sure
+            # if they support all the sub commands we need, order of
+            # most recent commit history:
+            # https://github.com/rr-/pyxdotool
+            # https://github.com/ShaneHutter/pyxdotool
+            # https://github.com/cphyc/pyxdotool

-                # TODO: only run the reconnect (2nd) kc on a detected
-                # disconnect?
-                for key_combo, timeout in [
-                    # only required if we need a connection reset.
-                    # ('ctrl+alt+r', 12),
-                    # data feed reset.
-                    ('ctrl+alt+f', 6)
-                ]:
-                    subprocess.call([
-                        'xdotool',
-                        'windowactivate', '--sync', win_id,
+            # TODO: only run the reconnect (2nd) kc on a detected
+            # disconnect?
+            for key_combo, timeout in [
+                # only required if we need a connection reset.
+                # ('ctrl+alt+r', 12),
+                # data feed reset.
+                ('ctrl+alt+f', 6)
+            ]:
+                subprocess.call([
+                    'xdotool',
+                    'windowactivate', '--sync', win_id,

-                        # move mouse to bottom left of window (where
-                        # there should be nothing to click).
-                        'mousemove_relative', '--sync', str(w-4), str(h-4),
+                    # move mouse to bottom left of window (where
+                    # there should be nothing to click).
+                    'mousemove_relative', '--sync', str(w-4), str(h-4),

-                        # NOTE: we may need to stick a `--retry 3` in here..
-                        'click', '--window', win_id,
-                        '--repeat', '3', '1',
+                    # NOTE: we may need to stick a `--retry 3` in here..
+                    'click', '--window', win_id,
+                    '--repeat', '3', '1',

-                        # hackzorzes
-                        'key', key_combo,
-                        ],
-                        timeout=timeout,
-                    )
+                    # hackzorzes
+                    'key', key_combo,
+                    ],
+                    timeout=timeout,
+                )

        # re-activate and focus original window
        subprocess.call([
--- a/piker/brokers/ib/api.py
+++ b/piker/brokers/ib/api.py
@ -48,6 +48,7 @@ from bidict import bidict
 import trio
 import tractor
 from tractor import to_asyncio
+from tractor import trionics
 from pendulum import (
    from_timestamp,
    DateTime,
@ -1369,8 +1370,8 @@ async def load_clients_for_trio(
    '''
    Pure async mngr proxy to ``load_aio_clients()``.

-    This is a bootstrap entrypoing to call from
-    a ``tractor.to_asyncio.open_channel_from()``.
+    This is a bootstrap entrypoint to call from
+    a `tractor.to_asyncio.open_channel_from()`.

    '''
    async with load_aio_clients(
@ -1391,7 +1392,10 @@ async def open_client_proxies() -> tuple[
    async with (
        tractor.trionics.maybe_open_context(
            acm_func=tractor.to_asyncio.open_channel_from,
-            kwargs={'target': load_clients_for_trio},
+            kwargs={
+                'target': load_clients_for_trio,
+                # ^XXX, kwarg to `open_channel_from()`
+            },

            # lock around current actor task access
            # TODO: maybe this should be the default in tractor?
@ -1584,7 +1588,8 @@ async def open_client_proxy(
            event_consumers=event_table,
        ) as (first, chan),

-        trio.open_nursery() as relay_n,
+        trionics.collapse_eg(),  # loose-ify
+        trio.open_nursery() as relay_tn,
    ):

        assert isinstance(first, Client)
@ -1624,7 +1629,7 @@ async def open_client_proxy(

                    continue

-        relay_n.start_soon(relay_events)
+        relay_tn.start_soon(relay_events)

        yield proxy

--- a/piker/brokers/ib/broker.py
+++ b/piker/brokers/ib/broker.py
@ -34,6 +34,7 @@ import trio
 from trio_typing import TaskStatus
 import tractor
 from tractor.to_asyncio import LinkedTaskChannel
+from tractor import trionics
 from ib_insync.contract import (
    Contract,
 )
@ -407,7 +408,7 @@ async def update_and_audit_pos_msg(

    # TODO: make this a "propaganda" log level?
    if ibpos.avgCost != msg.avg_price:
-        log.warning(
+        log.debug(
            f'IB "FIFO" avg price for {msg.symbol} is DIFF:\n'
            f'ib: {ibfmtmsg}\n'
            '---------------------------\n'
@ -738,7 +739,7 @@ async def open_trade_dialog(
                                f'UNEXPECTED POSITION says IB => {msg.symbol}\n'
                                'Maybe they LIQUIDATED YOU or your ledger is wrong?\n'
                            )
-                            log.error(logmsg)
+                            log.debug(logmsg)

            await ctx.started((
                all_positions,
@ -747,21 +748,22 @@ async def open_trade_dialog(

            async with (
                ctx.open_stream() as ems_stream,
-                trio.open_nursery() as n,
+                trionics.collapse_eg(),
+                trio.open_nursery() as tn,
            ):
                # relay existing open orders to ems
                for msg in order_msgs:
                    await ems_stream.send(msg)

                for client in set(aioclients.values()):
-                    trade_event_stream: LinkedTaskChannel = await n.start(
+                    trade_event_stream: LinkedTaskChannel = await tn.start(
                        open_trade_event_stream,
                        client,
                    )

                    # start order request handler **before** local trades
                    # event loop
-                    n.start_soon(
+                    tn.start_soon(
                        handle_order_requests,
                        ems_stream,
                        accounts_def,
@ -769,7 +771,7 @@ async def open_trade_dialog(
                    )

                    # allocate event relay tasks for each client connection
-                    n.start_soon(
+                    tn.start_soon(
                        deliver_trade_events,

                        trade_event_stream,
@ -1241,32 +1243,47 @@ async def deliver_trade_events(
                # never relay errors for non-broker related issues
                # https://interactivebrokers.github.io/tws-api/message_codes.html
                code: int = err['error_code']
-                if code in {
-                    200,  # uhh
+                reason: str = err['reason']
+                reqid: str = str(err['reqid'])
+
+                # "Warning:" msg codes,
+                # https://interactivebrokers.github.io/tws-api/message_codes.html#warning_codes
+                # - 2109: 'Outside Regular Trading Hours'
+                if 'Warning:' in reason:
+                    log.warning(
+                        f'Order-API-warning: {code!r}\n'
+                        f'reqid: {reqid!r}\n'
+                        f'\n'
+                        f'{pformat(err)}\n'
+                        # ^TODO? should we just print the `reason`
+                        # not the full `err`-dict?
+                    )
+                    continue
+
+                # XXX known special (ignore) cases
+                elif code in {
+                    200,  # uhh.. ni idea

                    # hist pacing / connectivity
                    162,
                    165,

-                    # WARNING codes:
-                    # https://interactivebrokers.github.io/tws-api/message_codes.html#warning_codes
-                    # Attribute 'Outside Regular Trading Hours' is
-                    # " 'ignored based on the order type and
-                    # destination. PlaceOrder is now ' 'being
-                    # processed.',
-                    2109,
-
                    # XXX: lol this isn't even documented..
                    # 'No market data during competing live session'
                    1669,
                }:
+                    log.error(
+                        f'Order-API-error which is non-cancel-causing ?!\n'
+                        f'\n'
+                        f'{pformat(err)}\n'
+                    )
                    continue

-                reqid: str = str(err['reqid'])
-                reason: str = err['reason']
-
                if err['reqid'] == -1:
-                    log.error(f'TWS external order error:\n{pformat(err)}')
+                    log.error(
+                        f'TWS external order error ??\n'
+                        f'{pformat(err)}\n'
+                    )

                flow: dict = dict(
                    flows.get(reqid)
--- a/piker/brokers/ib/feed.py
+++ b/piker/brokers/ib/feed.py
@ -587,7 +587,7 @@ async def get_bars(
                        data_cs.cancel()

                    # spawn new data reset task
-                    data_cs, reset_done = await nurse.start(
+                    data_cs, reset_done = await tn.start(
                        partial(
                            wait_on_data_reset,
                            proxy,
@ -607,11 +607,11 @@ async def get_bars(
    # such that simultaneous symbol queries don't try data resettingn
    # too fast..
    unset_resetter: bool = False
-    async with trio.open_nursery() as nurse:
+    async with trio.open_nursery() as tn:

        # start history request that we allow
        # to run indefinitely until a result is acquired
-        nurse.start_soon(query)
+        tn.start_soon(query)

        # start history reset loop which waits up to the timeout
        # for a result before triggering a data feed reset.
@ -631,7 +631,7 @@ async def get_bars(
                unset_resetter: bool = True

            # spawn new data reset task
-            data_cs, reset_done = await nurse.start(
+            data_cs, reset_done = await tn.start(
                partial(
                    wait_on_data_reset,
                    proxy,
@ -705,7 +705,9 @@ async def _setup_quote_stream(
        # to_trio, from_aio = trio.open_memory_channel(2**8)  # type: ignore
        def teardown():
            ticker.updateEvent.disconnect(push)
-            log.error(f"Disconnected stream for `{symbol}`")
+            log.error(
+                f'Disconnected stream for `{symbol}`'
+            )
            client.ib.cancelMktData(contract)

            # decouple broadcast mem chan
@ -761,7 +763,10 @@ async def open_aio_quote_stream(
    symbol: str,
    contract: Contract | None = None,

-) -> trio.abc.ReceiveStream:
+) -> (
+    trio.abc.Channel|  # iface
+    tractor.to_asyncio.LinkedTaskChannel  # actually
+):

    from tractor.trionics import broadcast_receiver
    global _quote_streams
@ -778,6 +783,7 @@ async def open_aio_quote_stream(
            yield from_aio
            return

+    from_aio: tractor.to_asyncio.LinkedTaskChannel
    async with tractor.to_asyncio.open_channel_from(
        _setup_quote_stream,
        symbol=symbol,
@ -983,17 +989,18 @@ async def stream_quotes(
        )
        cs: trio.CancelScope | None = None
        startup: bool = True
+        iter_quotes: trio.abc.Channel
        while (
            startup
            or cs.cancel_called
        ):
            with trio.CancelScope() as cs:
                async with (
-                    trio.open_nursery() as nurse,
+                    trio.open_nursery() as tn,
                    open_aio_quote_stream(
                        symbol=sym,
                        contract=con,
-                    ) as stream,
+                    ) as iter_quotes,
                ):
                    # ugh, clear ticks since we've consumed them
                    # (ahem, ib_insync is stateful trash)
@ -1021,9 +1028,9 @@ async def stream_quotes(
                        await rt_ev.wait()
                        cs.cancel()  # cancel called should now be set

-                    nurse.start_soon(reset_on_feed)
+                    tn.start_soon(reset_on_feed)

-                    async with aclosing(stream):
+                    async with aclosing(iter_quotes):
                        # if syminfo.get('no_vlm', False):
                        if not init_msg.shm_write_opts['has_vlm']:

@ -1038,19 +1045,21 @@ async def stream_quotes(
                            # wait for real volume on feed (trading might be
                            # closed)
                            while True:
-                                ticker = await stream.receive()
+                                ticker = await iter_quotes.receive()

                                # for a real volume contract we rait for
                                # the first "real" trade to take place
                                if (
                                    # not calc_price
                                    # and not ticker.rtTime
-                                    not ticker.rtTime
+                                    False
+                                    # not ticker.rtTime
                                ):
                                    # spin consuming tickers until we
                                    # get a real market datum
                                    log.debug(f"New unsent ticker: {ticker}")
                                    continue
+
                                else:
                                    log.debug("Received first volume tick")
                                    # ugh, clear ticks since we've
@ -1066,13 +1075,18 @@ async def stream_quotes(
                            log.debug(f"First ticker received {quote}")

                        # tell data-layer spawner-caller that live
-                        # quotes are now streaming.
+                        # quotes are now active desptie not having
+                        # necessarily received a first vlm/clearing
+                        # tick.
+                        ticker = await iter_quotes.receive()
                        feed_is_live.set()
+                        fqme: str = quote['fqme']
+                        await send_chan.send({fqme: quote})

                        # last = time.time()
-                        async for ticker in stream:
+                        async for ticker in iter_quotes:
                            quote = normalize(ticker)
-                            fqme = quote['fqme']
+                            fqme: str = quote['fqme']
                            await send_chan.send({fqme: quote})

                            # ugh, clear ticks since we've consumed them
--- a/piker/brokers/kraken/api.py
+++ b/piker/brokers/kraken/api.py
@ -34,6 +34,7 @@ import urllib.parse
 import hashlib
 import hmac
 import base64
+import tractor
 import trio

 from piker import config
@ -372,8 +373,7 @@ class Client:
        #     1658347714, 'status': 'Success'}]}

        if xfers:
-            import tractor
-            await tractor.pp()
+            await tractor.pause()

        trans: dict[str, Transaction] = {}
        for entry in xfers:
@ -501,7 +501,8 @@ class Client:
            for xkey, data in resp['result'].items():

                # NOTE: always cache in pairs tables for faster lookup
-                pair = Pair(xname=xkey, **data)
+                with tractor.devx.maybe_open_crash_handler(): # as bxerr:
+                    pair = Pair(xname=xkey, **data)

                # register the above `Pair` structs for all
                # key-sets/monikers: a set of 4 (frickin) tables
--- a/piker/brokers/kraken/broker.py
+++ b/piker/brokers/kraken/broker.py
@ -175,9 +175,8 @@ async def handle_order_requests(

            case {
                'account': 'kraken.spot' as account,
-                'action': action,
-            } if action in {'buy', 'sell'}:
-
+                'action': 'buy'|'sell',
+            }:
                # validate
                order = BrokerdOrder(**msg)

@ -262,6 +261,12 @@ async def handle_order_requests(
                } | extra

                log.info(f'Submitting WS order request:\n{pformat(req)}')
+
+                # NOTE HOWTO, debug order requests
+                #
+                # if 'XRP' in pair:
+                #     await tractor.pause()
+
                await ws.send_msg(req)

                # placehold for sanity checking in relay loop
@ -544,7 +549,7 @@ async def open_trade_dialog(
            # to be reloaded.
            balances: dict[str, float] = await client.get_balances()

-            verify_balances(
+            await verify_balances(
                acnt,
                src_fiat,
                balances,
@ -1085,6 +1090,8 @@ async def handle_order_updates(
                        f'Failed to {action} order {reqid}:\n'
                        f'{errmsg}'
                    )
+                    # if tractor._state.debug_mode():
+                    #     await tractor.pause()

                    symbol: str = 'N/A'
                    if chain := apiflows.get(reqid):
--- a/piker/brokers/kraken/symbols.py
+++ b/piker/brokers/kraken/symbols.py
@ -21,7 +21,6 @@ Symbology defs and search.
 from decimal import Decimal

 import tractor
-from rapidfuzz import process as fuzzy

 from piker._cacheables import (
    async_lifo_cache,
@ -41,8 +40,13 @@ from piker.accounting._mktinfo import (
 )


-# https://www.kraken.com/features/api#get-tradable-pairs
 class Pair(Struct):
+    '''
+    A tradable asset pair as schema-defined by,
+
+    https://docs.kraken.com/api/docs/rest-api/get-tradable-asset-pairs
+
+    '''
    xname: str  # idiotic bs_mktid equiv i guess?
    altname: str  # alternate pair name
    wsname: str  # WebSocket pair name (if available)
@ -53,7 +57,6 @@ class Pair(Struct):
    lot: str  # volume lot size

    cost_decimals: int
-    costmin: float
    pair_decimals: int  # scaling decimal places for pair
    lot_decimals: int  # scaling decimal places for volume

@ -79,6 +82,7 @@ class Pair(Struct):
    tick_size: float  # min price step size
    status: str

+    costmin: str|None = None  # XXX, only some mktpairs?
    short_position_limit: float = 0
    long_position_limit: float = float('inf')

--- a/piker/brokers/questrade.py
+++ b/piker/brokers/questrade.py
@ -37,6 +37,12 @@ import tractor
 from async_generator import asynccontextmanager
 import numpy as np
 import wrapt
+
+# TODO, port to `httpx`/`trio-websocket` whenver i get back to
+# writing a proper ws-api streamer for this backend (since the data
+# feeds are free now) as per GH feat-req:
+# https://github.com/pikers/piker/issues/509
+#
 import asks

 from ..calc import humanize, percent_change
--- a/piker/clearing/_client.py
+++ b/piker/clearing/_client.py
@ -25,7 +25,10 @@ from typing import TYPE_CHECKING

 import trio
 import tractor
-from tractor.trionics import broadcast_receiver
+from tractor.trionics import (
+    broadcast_receiver,
+    collapse_eg,
+)

 from ._util import (
    log,  # sub-sys logger
@ -285,8 +288,11 @@ async def open_ems(
            client._ems_stream = trades_stream

            # start sync code order msg delivery task
-            async with trio.open_nursery() as n:
-                n.start_soon(
+            async with (
+                collapse_eg(),
+                trio.open_nursery() as tn,
+            ):
+                tn.start_soon(
                    relay_orders_from_sync_code,
                    client,
                    fqme,
@ -302,4 +308,4 @@ async def open_ems(
                )

                # stop the sync-msg-relay task on exit.
-                n.cancel_scope.cancel()
+                tn.cancel_scope.cancel()
--- a/piker/clearing/_ems.py
+++ b/piker/clearing/_ems.py
@ -42,6 +42,7 @@ from bidict import bidict
 import trio
 from trio_typing import TaskStatus
 import tractor
+from tractor import trionics

 from ._util import (
    log,  # sub-sys logger
@ -76,7 +77,6 @@ if TYPE_CHECKING:

 # TODO: numba all of this
 def mk_check(
-
    trigger_price: float,
    known_last: float,
    action: str,
@ -162,7 +162,7 @@ async def clear_dark_triggers(

    router: Router,
    brokerd_orders_stream: tractor.MsgStream,
-    quote_stream: tractor.ReceiveMsgStream,  # noqa
+    quote_stream: tractor.MsgStream,
    broker: str,
    fqme: str,

@ -178,6 +178,7 @@ async def clear_dark_triggers(
    '''
    # XXX: optimize this for speed!
    # TODO:
+    # - port to the new ringbuf stuff in `tractor.ipc`!
    # - numba all this!
    # - this stream may eventually contain multiple symbols
    quote_stream._raise_on_lag = False
@ -500,7 +501,7 @@ class Router(Struct):

    '''
    # setup at actor spawn time
-    nursery: trio.Nursery
+    _tn: trio.Nursery

    # broker to book map
    books: dict[str, DarkBook] = {}
@ -670,7 +671,7 @@ class Router(Struct):
                # dark book clearing loop, also lives with parent
                # daemon to allow dark order clearing while no
                # client is connected.
-                self.nursery.start_soon(
+                self._tn.start_soon(
                    clear_dark_triggers,
                    self,
                    relay.brokerd_stream,
@ -693,7 +694,7 @@ class Router(Struct):

                # spawn a ``brokerd`` order control dialog stream
                # that syncs lifetime with the parent `emsd` daemon.
-                self.nursery.start_soon(
+                self._tn.start_soon(
                    translate_and_relay_brokerd_events,
                    broker,
                    relay.brokerd_stream,
@ -767,10 +768,12 @@ async def _setup_persistent_emsd(

    global _router

-    # open a root "service nursery" for the ``emsd`` actor
-    async with trio.open_nursery() as service_nursery:
-
-        _router = Router(nursery=service_nursery)
+    # open a root "service task-nursery" for the `emsd`-actor
+    async with (
+        trionics.collapse_eg(),
+        trio.open_nursery() as tn
+    ):
+        _router = Router(_tn=tn)

        # TODO: send back the full set of persistent
        # orders/execs?
@ -1190,12 +1193,16 @@ async def process_client_order_cmds(
    submitting live orders immediately if requested by the client.

    '''
-    # cmd: dict
+    # TODO, only allow `msgspec.Struct` form!
+    cmd: dict
    async for cmd in client_order_stream:
-        log.info(f'Received order cmd:\n{pformat(cmd)}')
+        log.info(
+            f'Received order cmd:\n'
+            f'{pformat(cmd)}\n'
+        )

        # CAWT DAMN we need struct support!
-        oid = str(cmd['oid'])
+        oid: str = str(cmd['oid'])

        # register this stream as an active order dialog (msg flow) for
        # this order id such that translated message from the brokerd
@ -1301,7 +1308,7 @@ async def process_client_order_cmds(
            case {
                'oid': oid,
                'symbol': fqme,
-                'price': trigger_price,
+                'price': price,
                'size': size,
                'action': ('buy' | 'sell') as action,
                'exec_mode': ('live' | 'paper'),
@ -1333,7 +1340,7 @@ async def process_client_order_cmds(

                    symbol=sym,
                    action=action,
-                    price=trigger_price,
+                    price=price,
                    size=size,
                    account=req.account,
                )
@ -1355,7 +1362,11 @@ async def process_client_order_cmds(
                # (``translate_and_relay_brokerd_events()`` above) will
                # handle relaying the ems side responses back to
                # the client/cmd sender from this request
-                log.info(f'Sending live order to {broker}:\n{pformat(msg)}')
+                log.info(
+                    f'Sending live order to {broker}:\n'
+                    f'{pformat(msg)}'
+                )
+
                await brokerd_order_stream.send(msg)

                # an immediate response should be ``BrokerdOrderAck``
@ -1371,7 +1382,7 @@ async def process_client_order_cmds(
            case {
                'oid': oid,
                'symbol': fqme,
-                'price': trigger_price,
+                'price': price,
                'size': size,
                'exec_mode': exec_mode,
                'action': action,
@ -1399,7 +1410,12 @@ async def process_client_order_cmds(
                if isnan(last):
                    last = flume.rt_shm.array[-1]['close']

-                pred = mk_check(trigger_price, last, action)
+                trigger_price: float = float(price)
+                pred = mk_check(
+                    trigger_price,
+                    last,
+                    action,
+                )

                # NOTE: for dark orders currently we submit
                # the triggered live order at a price 5 ticks
@ -1506,7 +1522,7 @@ async def maybe_open_trade_relays(
        loglevel: str = 'info',
    ):

-        fqme, relay, feed, client_ready = await _router.nursery.start(
+        fqme, relay, feed, client_ready = await _router._tn.start(
            _router.open_trade_relays,
            fqme,
            exec_mode,
@ -1539,7 +1555,7 @@ async def _emsd_main(
    ctx: tractor.Context,
    fqme: str,
    exec_mode: str,  # ('paper', 'live')
-    loglevel: str | None = None,
+    loglevel: str|None = None,

 ) -> tuple[
    dict[
--- a/piker/clearing/_messages.py
+++ b/piker/clearing/_messages.py
@ -19,6 +19,7 @@ Clearing sub-system message and protocols.

 """
 from __future__ import annotations
+from decimal import Decimal
 from typing import (
    Literal,
 )
@ -71,7 +72,15 @@ class Order(Struct):
    symbol: str  # | MktPair
    account: str  # should we set a default as '' ?

-    price: float
+    # https://docs.python.org/3/library/decimal.html#decimal-objects
+    #
+    # ?TODO? decimal usage throughout?
+    # -[ ] possibly leverage the `Encoder(decimal_format='number')`
+    #  bit?
+    # |_https://jcristharif.com/msgspec/supported-types.html#decimal
+    # -[ ] should we also use it for .size?
+    #
+    price: Decimal
    size: float  # -ve is "sell", +ve is "buy"

    brokers: list[str] = []
@ -178,7 +187,7 @@ class BrokerdOrder(Struct):
    time_ns: int

    symbol: str  # fqme
-    price: float
+    price: Decimal
    size: float

    # TODO: if we instead rely on a +ve/-ve size to determine
--- a/piker/clearing/_paper_engine.py
+++ b/piker/clearing/_paper_engine.py
@ -510,7 +510,7 @@ async def handle_order_requests(
                reqid = await client.submit_limit(
                    oid=order.oid,
                    symbol=f'{order.symbol}.{client.broker}',
-                    price=order.price,
+                    price=float(order.price),
                    action=order.action,
                    size=order.size,
                    # XXX: by default 0 tells ``ib_insync`` methods that
@ -655,6 +655,7 @@ async def open_trade_dialog(
                # in) use manually constructed table from calling
                # the `.get_mkt_info()` provider EP above.
                _mktmap_table=mkt_by_fqme,
+                only_require=list(mkt_by_fqme),
            )

            pp_msgs: list[BrokerdPosition] = []
--- a/piker/cli/init.py
+++ b/piker/cli/init.py
@ -184,33 +184,12 @@ def pikerd(
                    registry_addrs=regaddrs,
                    loglevel=loglevel,
                    debug_mode=pdb,
-
-                ) as service_mngr,  # normally delivers a ``Services`` handle
-
-                # AsyncExitStack() as stack,
+                    enable_transports=['uds'],
+                ) as service_mngr,
            ):
-                # TODO: spawn all other sub-actor daemons according to
-                # multiaddress endpoint spec defined by user config
                assert service_mngr
-
-                # if tsdb:
-                #     dname, conf = await stack.enter_async_context(
-                #         service.marketstore.start_ahab_daemon(
-                #             service_mngr,
-                #             loglevel=loglevel,
-                #         )
-                #     )
-                #     log.info(f'TSDB `{dname}` up with conf:\n{conf}')
-
-                # if es:
-                #     dname, conf = await stack.enter_async_context(
-                #         service.elastic.start_ahab_daemon(
-                #             service_mngr,
-                #             loglevel=loglevel,
-                #         )
-                #     )
-                #     log.info(f'DB `{dname}` up with conf:\n{conf}')
-
+                # ?TODO? spawn all other sub-actor daemons according to
+                # multiaddress endpoint spec defined by user config
                await trio.sleep_forever()

        trio.run(main)
@ -335,7 +314,7 @@ def services(config, tl, ports):
                name='service_query',
                loglevel=config['loglevel'] if tl else None,
            ),
-            tractor.get_arbiter(
+            tractor.get_registry(
                host=host,
                port=ports[0]
            ) as portal
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@ -740,7 +740,7 @@ async def sample_and_broadcast(

                                log.warning(
                                    f'Feed OVERRUN {sub_key}'
-                                    '@{bus.brokername} -> \n'
+                                    f'@{bus.brokername} -> \n'
                                    f'feed @ {chan.uid}\n'
                                    f'throttle = {throttle} Hz'
                                )
--- a/piker/data/_symcache.py
+++ b/piker/data/_symcache.py
@ -31,6 +31,7 @@ from pathlib import Path
 from pprint import pformat
 from typing import (
    Any,
+    Callable,
    Sequence,
    Hashable,
    TYPE_CHECKING,
@ -56,7 +57,7 @@ from piker.brokers import (
 )

 if TYPE_CHECKING:
-    from ..accounting import (
+    from piker.accounting import (
        Asset,
        MktPair,
    )
@ -149,57 +150,68 @@ class SymbologyCache(Struct):
                    'Implement `Client.get_assets()`!'
                )

-            if get_mkt_pairs := getattr(client, 'get_mkt_pairs', None):
-
-                pairs: dict[str, Struct] = await get_mkt_pairs()
-                for bs_fqme, pair in pairs.items():
-
-                    # NOTE: every backend defined pair should
-                    # declare it's ns path for roundtrip
-                    # serialization lookup.
-                    if not getattr(pair, 'ns_path', None):
-                        raise TypeError(
-                            f'Pair-struct for {self.mod.name} MUST define a '
-                            '`.ns_path: str`!\n'
-                            f'{pair}'
-                        )
-
-                    entry = await self.mod.get_mkt_info(pair.bs_fqme)
-                    if not entry:
-                        continue
-
-                    mkt: MktPair
-                    pair: Struct
-                    mkt, _pair = entry
-                    assert _pair is pair, (
-                        f'`{self.mod.name}` backend probably has a '
-                        'keying-symmetry problem between the pair-`Struct` '
-                        'returned from `Client.get_mkt_pairs()`and the '
-                        'module level endpoint: `.get_mkt_info()`\n\n'
-                        "Here's the struct diff:\n"
-                        f'{_pair - pair}'
-                    )
-                    # NOTE XXX: this means backends MUST implement
-                    # a `Struct.bs_mktid: str` field to provide
-                    # a native-keyed map to their own symbol
-                    # set(s).
-                    self.pairs[pair.bs_mktid] = pair
-
-                    # NOTE: `MktPair`s are keyed here using piker's
-                    # internal FQME schema so that search,
-                    # accounting and feed init can be accomplished
-                    # a sane, uniform, normalized basis.
-                    self.mktmaps[mkt.fqme] = mkt
-
-                self.pair_ns_path: str = tractor.msg.NamespacePath.from_ref(
-                    pair,
-                )
-
-            else:
+            get_mkt_pairs: Callable|None = getattr(
+                client,
+                'get_mkt_pairs',
+                None,
+            )
+            if not get_mkt_pairs:
                log.warning(
                    'No symbology cache `Pair` support for `{provider}`..\n'
                    'Implement `Client.get_mkt_pairs()`!'
                )
+                return self
+
+            pairs: dict[str, Struct] = await get_mkt_pairs()
+            if not pairs:
+                log.warning(
+                    'No pairs from intial {provider!r} sym-cache request?\n\n'
+                    '`Client.get_mkt_pairs()` -> {pairs!r} ?'
+                )
+                return self
+
+            for bs_fqme, pair in pairs.items():
+                if not getattr(pair, 'ns_path', None):
+                    # XXX: every backend defined pair must declare
+                    # a `.ns_path: tractor.NamespacePath` to enable
+                    # roundtrip serialization lookup from a local
+                    # cache file.
+                    raise TypeError(
+                        f'Pair-struct for {self.mod.name} MUST define a '
+                        '`.ns_path: str`!\n\n'
+                        f'{pair!r}'
+                    )
+
+                entry = await self.mod.get_mkt_info(pair.bs_fqme)
+                if not entry:
+                    continue
+
+                mkt: MktPair
+                pair: Struct
+                mkt, _pair = entry
+                assert _pair is pair, (
+                    f'`{self.mod.name}` backend probably has a '
+                    'keying-symmetry problem between the pair-`Struct` '
+                    'returned from `Client.get_mkt_pairs()`and the '
+                    'module level endpoint: `.get_mkt_info()`\n\n'
+                    "Here's the struct diff:\n"
+                    f'{_pair - pair}'
+                )
+                # NOTE XXX: this means backends MUST implement
+                # a `Struct.bs_mktid: str` field to provide
+                # a native-keyed map to their own symbol
+                # set(s).
+                self.pairs[pair.bs_mktid] = pair
+
+                # NOTE: `MktPair`s are keyed here using piker's
+                # internal FQME schema so that search,
+                # accounting and feed init can be accomplished
+                # a sane, uniform, normalized basis.
+                self.mktmaps[mkt.fqme] = mkt
+
+            self.pair_ns_path: str = tractor.msg.NamespacePath.from_ref(
+                pair,
+            )

        return self

--- a/piker/data/feed.py
+++ b/piker/data/feed.py
@ -39,6 +39,7 @@ from typing import (
    AsyncContextManager,
    Awaitable,
    Sequence,
+    TYPE_CHECKING,
 )

 import trio
@ -75,6 +76,10 @@ from ._sampling import (
    uniform_rate_send,
 )

+if TYPE_CHECKING:
+    from tractor._addr import Address
+    from tractor.msg.types import Aid
+

 class Sub(Struct, frozen=True):
    '''
@ -723,7 +728,10 @@ class Feed(Struct):
                async for msg in stream:
                    await tx.send(msg)

-        async with trio.open_nursery() as nurse:
+        async with (
+            tractor.trionics.collapse_eg(),
+            trio.open_nursery() as nurse
+        ):
            # spawn a relay task for each stream so that they all
            # multiplex to a common channel.
            for brokername in mods:
@ -786,7 +794,6 @@ async def install_brokerd_search(

@acm
 async def maybe_open_feed(
-
    fqmes: list[str],
    loglevel: str | None = None,

@ -840,13 +847,12 @@ async def maybe_open_feed(

@acm
 async def open_feed(
-
    fqmes: list[str],

-    loglevel: str | None = None,
+    loglevel: str|None = None,
    allow_overruns: bool = True,
    start_stream: bool = True,
-    tick_throttle: float | None = None,  # Hz
+    tick_throttle: float|None = None,  # Hz

    allow_remote_ctl_ui: bool = False,

@ -899,19 +905,19 @@ async def open_feed(
            feed.portals[brokermod] = portal

            # fill out "status info" that the UI can show
-            host, port = portal.channel.raddr
-            if host == '127.0.0.1':
-                host = 'localhost'
-
+            chan: tractor.Channel = portal.chan
+            raddr: Address = chan.raddr
+            aid: Aid = chan.aid
+            # TAG_feed_status_update
            feed.status.update({
-                'actor_name': portal.channel.uid[0],
-                'host': host,
-                'port': port,
+                'actor_id': aid,
+                'actor_short_id': f'{aid.name}@{aid.pid}',
+                'ipc': chan.raddr.proto_key,
+                'ipc_addr': raddr,
                'hist_shm': 'NA',
                'rt_shm': 'NA',
-                'throttle_rate': tick_throttle,
+                'throttle_hz': tick_throttle,
            })
-            # feed.status.update(init_msg.pop('status', {}))

            # (allocate and) connect to any feed bus for this broker
            bus_ctxs.append(
--- a/piker/data/flows.py
+++ b/piker/data/flows.py
@ -36,10 +36,10 @@ from ._sharedmem import (
    ShmArray,
    _Token,
 )
+from piker.accounting import MktPair

 if TYPE_CHECKING:
-    from ..accounting import MktPair
-    from .feed import Feed
+    from piker.data.feed import Feed


 class Flume(Struct):
@ -82,7 +82,7 @@ class Flume(Struct):

    # TODO: do we need this really if we can pull the `Portal` from
    # ``tractor``'s internals?
-    feed: Feed | None = None
+    feed: Feed|None = None

    @property
    def rt_shm(self) -> ShmArray:
--- a/piker/data/validate.py
+++ b/piker/data/validate.py
@ -113,9 +113,9 @@ def validate_backend(
            )
            if ep is None:
                log.warning(
-                    f'Provider backend {mod.name} is missing '
-                    f'{daemon_name} support :(\n'
-                    f'The following endpoint is missing: {name}'
+                    f'Provider backend {mod.name!r} is missing '
+                    f'{daemon_name!r} support?\n'
+                    f'|_module endpoint-func missing: {name!r}\n'
                )

    inits: list[
--- a/piker/fsp/_engine.py
+++ b/piker/fsp/_engine.py
@ -498,6 +498,7 @@ async def cascade(

        func_name: str = func.__name__
        async with (
+            tractor.trionics.collapse_eg(),  # avoid multi-taskc tb in console
            trio.open_nursery() as tn,
        ):
            # TODO: might be better to just make a "restart" method where
--- a/piker/service/_actor_runtime.py
+++ b/piker/service/_actor_runtime.py
@ -200,7 +200,8 @@ async def open_pikerd(
            reg_addrs,
        ),
        tractor.open_nursery() as actor_nursery,
-        trio.open_nursery() as service_nursery,
+        tractor.trionics.collapse_eg(),
+        trio.open_nursery() as service_tn,
    ):
        for addr in reg_addrs:
            if addr not in root_actor.accept_addrs:
@ -211,7 +212,7 @@ async def open_pikerd(

        # assign globally for future daemon/task creation
        Services.actor_n = actor_nursery
-        Services.service_n = service_nursery
+        Services.service_n = service_tn
        Services.debug_mode = debug_mode

        try:
@ -221,7 +222,7 @@ async def open_pikerd(
            # TODO: is this more clever/efficient?
            # if 'samplerd' in Services.service_tasks:
            #     await Services.cancel_service('samplerd')
-            service_nursery.cancel_scope.cancel()
+            service_tn.cancel_scope.cancel()


 # TODO: do we even need this?
--- a/piker/tsp/init.py
+++ b/piker/tsp/init.py
@ -963,7 +963,10 @@ async def tsdb_backfill(
        # concurrently load the provider's most-recent-frame AND any
        # pre-existing tsdb history already saved in `piker` storage.
        dt_eps: list[DateTime, DateTime] = []
-        async with trio.open_nursery() as tn:
+        async with (
+            tractor.trionics.collapse_eg(),
+            trio.open_nursery() as tn
+        ):
            tn.start_soon(
                push_latest_frame,
                dt_eps,
@ -1012,9 +1015,16 @@ async def tsdb_backfill(
                int,
                Duration,
            ]|None = config.get('frame_types', None)
+
            if def_frame_durs:
                def_frame_size: Duration = def_frame_durs[timeframe]
-                assert def_frame_size == calced_frame_size
+
+                if def_frame_size != calced_frame_size:
+                    log.warning(
+                        f'Expected frame size {def_frame_size}\n'
+                        f'Rxed frame {calced_frame_size}\n'
+                    )
+                    # await tractor.pause()
            else:
                # use what we calced from first frame above.
                def_frame_size = calced_frame_size
@ -1043,7 +1053,9 @@ async def tsdb_backfill(
            # if there is a gap to backfill from the first
            # history frame until the last datum loaded from the tsdb
            # continue that now in the background
-            async with trio.open_nursery() as tn:
+            async with trio.open_nursery(
+                strict_exception_groups=False,
+            ) as tn:

                bf_done = await tn.start(
                    partial(
@ -1308,6 +1320,7 @@ async def manage_history(
        # sampling period) data set since normally differently
        # sampled timeseries can be loaded / process independently
        # ;)
+        tractor.trionics.collapse_eg(),
        trio.open_nursery() as tn,
    ):
        log.info(
--- a/piker/tsp/_anal.py
+++ b/piker/tsp/_anal.py
@ -517,7 +517,7 @@ def with_dts(

    '''
    return df.with_columns([
-        pl.col(time_col).shift(1).suffix('_prev'),
+        pl.col(time_col).shift(1).name.suffix('_prev'),
        pl.col(time_col).diff().alias('s_diff'),
        pl.from_epoch(pl.col(time_col)).alias('dt'),
    ]).with_columns([
@ -623,7 +623,7 @@ def detect_vlm_gaps(

 ) -> pl.DataFrame:

-    vnull: pl.DataFrame = w_dts.filter(
+    vnull: pl.DataFrame = df.filter(
        pl.col(col) == 0
    )
    return vnull
--- a/piker/ui/_app.py
+++ b/piker/ui/_app.py
@ -21,6 +21,7 @@ Main app startup and run.
 from functools import partial
 from types import ModuleType

+import tractor
 import trio

 from piker.ui.qt import (
@ -116,6 +117,7 @@ async def _async_main(
        needed_brokermods[brokername] = brokers[brokername]

    async with (
+        tractor.trionics.collapse_eg(),
        trio.open_nursery() as root_n,
    ):
        # set root nursery and task stack for spawning other charts/feeds
--- a/piker/ui/_chart.py
+++ b/piker/ui/_chart.py
@ -33,7 +33,6 @@ import trio

 from piker.ui.qt import (
    QtCore,
-    QtWidgets,
    Qt,
    QLineF,
    QFrame,
--- a/piker/ui/_display.py
+++ b/piker/ui/_display.py
@ -1445,7 +1445,10 @@ async def display_symbol_data(
        # for pause/resume on mouse interaction
        rt_chart.feed = feed

-        async with trio.open_nursery() as ln:
+        async with (
+            tractor.trionics.collapse_eg(),
+            trio.open_nursery() as ln,
+        ):
            # if available load volume related built-in display(s)
            vlm_charts: dict[
                str,
--- a/piker/ui/_event.py
+++ b/piker/ui/_event.py
@ -22,7 +22,10 @@ from contextlib import asynccontextmanager as acm
 from typing import Callable

 import trio
-from tractor.trionics import gather_contexts
+from tractor.trionics import (
+    gather_contexts,
+    collapse_eg,
+)

 from piker.ui.qt import (
    QtCore,
@ -207,7 +210,10 @@ async def open_signal_handler(
        async for args in recv:
            await async_handler(*args)

-    async with trio.open_nursery() as tn:
+    async with (
+        collapse_eg(),
+        trio.open_nursery() as tn
+    ):
        tn.start_soon(proxy_to_handler)
        async with send:
            yield
@ -242,6 +248,7 @@ async def open_handlers(
    widget: QWidget
    streams: list[trio.abc.ReceiveChannel]
    async with (
+        collapse_eg(),
        trio.open_nursery() as tn,
        gather_contexts([
            open_event_stream(
--- a/piker/ui/_feedstatus.py
+++ b/piker/ui/_feedstatus.py
@ -18,10 +18,11 @@
 Feed status and controls widget(s) for embedding in a UI-pane.

 """
-
 from __future__ import annotations
-from textwrap import dedent
-from typing import TYPE_CHECKING
+from typing import (
+    Any,
+    TYPE_CHECKING,
+)

 # from PyQt5.QtCore import Qt

@ -49,35 +50,55 @@ def mk_feed_label(
    a feed control protocol.

    '''
-    status = feed.status
+    status: dict[str, Any] = feed.status
    assert status

-    msg = dedent("""
-        actor: **{actor_name}**\n
-        |_ @**{host}:{port}**\n
-    """)
+    # SO tips on ws/nls,
+    # https://stackoverflow.com/a/15721400
+    ws: str = '&nbsp;'
+    # nl: str = '<br>'  # dun work?
+    actor_info_repr: str = (
+        f')> **{status["actor_short_id"]}**\n'
+        '\n'  # bc md?
+    )

-    for key, val in status.items():
-        if key in ('host', 'port', 'actor_name'):
-            continue
-        msg += f'\n|_ {key}: **{{{key}}}**\n'
+    # fields to select *IN* for display
+    # (see `.data.feed.open_feed()` status
+    #  update -> TAG_feed_status_update)
+    for key in [
+        'ipc',
+        'hist_shm',
+        'rt_shm',
+        'throttle_hz',
+    ]:
+        # NOTE, the 2nd key is filled via `.format()` updates.
+        actor_info_repr += (
+            f'\n'  # bc md?
+            f'{ws}|_{key}: **{{{key}}}**\n'
+        )
+        # ^TODO? formatting and content..
+        # -[ ] showing which fqme is "forward" on the
+        #    chart/fsp/order-mode?
+        #  '|_ flows: **{symbols}**\n'
+        #
+        # -[x] why isn't the indent working?
+        #  => markdown, now solved..

    feed_label = FormatLabel(
-        fmt_str=msg,
-        # |_ streams: **{symbols}**\n
+        fmt_str=actor_info_repr,
        font=_font.font,
        font_size=_font_small.px_size,
        font_color='default_lightest',
    )

+    # ?TODO, remove this?
    # form.vbox.setAlignment(feed_label, Qt.AlignBottom)
    # form.vbox.setAlignment(Qt.AlignBottom)
-    _ = chart.height() - (
-        form.height() +
-        form.fill_bar.height()
-        # feed_label.height()
-    )
+    # _ = chart.height() - (
+    #     form.height() +
+    #     form.fill_bar.height()
+    #     # feed_label.height()
+    # )

    feed_label.format(**feed.status)
-
    return feed_label
--- a/piker/ui/_fsp.py
+++ b/piker/ui/_fsp.py
@ -600,6 +600,7 @@ async def open_fsp_admin(
            kwargs=kwargs,
        ) as (cache_hit, cluster_map),

+        tractor.trionics.collapse_eg(),
        trio.open_nursery() as tn,
    ):
        if cache_hit:
@ -613,6 +614,8 @@ async def open_fsp_admin(
        )
        try:
            yield admin
+
+        # ??TODO, does this *need* to be inside a finally?
        finally:
            # terminate all tasks via signals
            for key, entry in admin._registry.items():
--- a/piker/ui/_label.py
+++ b/piker/ui/_label.py
@ -285,18 +285,20 @@ class FormatLabel(QLabel):
        font_size: int,
        font_color: str,

+        use_md: bool = True,
+
        parent=None,

    ) -> None:

        super().__init__(parent)

-        # by default set the format string verbatim and expect user to
-        # call ``.format()`` later (presumably they'll notice the
+        # by default set the format string verbatim and expect user
+        # to call ``.format()`` later (presumably they'll notice the
        # unformatted content if ``fmt_str`` isn't meant to be
        # unformatted).
        self.fmt_str = fmt_str
-        self.setText(fmt_str)
+        # self.setText(fmt_str)  # ?TODO, why here?

        self.setStyleSheet(
            f"""QLabel {{
@ -306,9 +308,10 @@ class FormatLabel(QLabel):
            """
        )
        self.setFont(_font.font)
-        self.setTextFormat(
-            Qt.TextFormat.MarkdownText
-        )
+        if use_md:
+            self.setTextFormat(
+                Qt.TextFormat.MarkdownText
+            )
        self.setMargin(0)

        self.setSizePolicy(
@ -316,7 +319,10 @@ class FormatLabel(QLabel):
            size_policy.Expanding,
        )
        self.setAlignment(
-            Qt.AlignVCenter | Qt.AlignLeft
+            Qt.AlignLeft
+            |
+            Qt.AlignBottom
+            # Qt.AlignVCenter
        )
        self.setText(self.fmt_str)

--- a/piker/ui/_style.py
+++ b/piker/ui/_style.py
@ -269,6 +269,8 @@ def hcolor(name: str) -> str:

        # default ohlc-bars/curve gray
        'bracket': '#666666',  # like the logo
+        'pikers': '#616161',  # a trader shade of..
+        'beast': '#161616',  # in the dark alone.

        # bluish
        'charcoal': '#36454F',
--- a/piker/ui/order_mode.py
+++ b/piker/ui/order_mode.py
@ -21,6 +21,7 @@ Chart trading, the only way to scalp.
 from __future__ import annotations
 from contextlib import asynccontextmanager
 from dataclasses import dataclass, field
+from decimal import Decimal
 from functools import partial
 from pprint import pformat
 import time
@ -41,7 +42,6 @@ from piker.accounting import (
    Position,
    mk_allocator,
    MktPair,
-    Symbol,
 )
 from piker.clearing import (
    open_ems,
@ -143,6 +143,15 @@ class OrderMode:
    }
    _staged_order: Order | None = None

+    @property
+    def curr_mkt(self) -> MktPair:
+        '''
+        Deliver the currently selected `MktPair` according
+        chart state.
+
+        '''
+        return self.chart.linked.mkt
+
    def on_level_change_update_next_order_info(
        self,
        level: float,
@ -172,7 +181,11 @@ class OrderMode:
        line.update_labels(order_info)

        # update bound-in staged order
-        order.price = level
+        mkt: MktPair = self.curr_mkt
+        order.price: Decimal = mkt.quantize(
+            size=level,
+            quantity_type='price',
+        )
        order.size = order_info['size']

        # when an order is changed we flip the settings side-pane to
@ -187,7 +200,9 @@ class OrderMode:

    ) -> LevelLine:

-        level = order.price
+        # TODO, if we instead just always decimalize at the ems layer
+        # we can avoid this back-n-forth casting?
+        level = float(order.price)

        line = order_line(
            chart or self.chart,
@ -224,7 +239,11 @@ class OrderMode:
            # the order mode allocator but we still need to update the
            # "staged" order message we'll send to the ems
            def update_order_price(y: float) -> None:
-                order.price = y
+                mkt: MktPair = self.curr_mkt
+                order.price: Decimal = mkt.quantize(
+                    size=y,
+                    quantity_type='price',
+                )

            line._on_level_change = update_order_price

@ -275,34 +294,31 @@ class OrderMode:
        chart = cursor.linked.chart
        if (
            not chart
-            and cursor
-            and cursor.active_plot
+            and
+            cursor
+            and
+            cursor.active_plot
        ):
            return

        chart = cursor.active_plot
-        price = cursor._datum_xy[1]
+        price: float = cursor._datum_xy[1]
        if not price:
            # zero prices are not supported by any means
            # since that's illogical / a no-op.
            return

-        mkt: MktPair = self.chart.linked.mkt
-
-        # NOTE : we could also use instead,
-        # mkt.quantize(price, quantity_type='price')
-        # but it returns a Decimal and it's probably gonna
-        # be slower?
        # TODO: should we be enforcing this precision
-        # at a different layer in the stack? right now
-        # any precision error will literally be relayed
-        # all the way back from the backend.
-
-        price = round(
-            price,
-            ndigits=mkt.price_tick_digits,
+        # at a different layer in the stack?
+        # |_ might require `MktPair` tracking in the EMS?
+        # |_ right now any precision error will be relayed
+        #    all the way back from the backend and vice-versa..
+        #
+        mkt: MktPair = self.curr_mkt
+        price: Decimal = mkt.quantize(
+            size=price,
+            quantity_type='price',
        )
-
        order = self._staged_order = Order(
            action=action,
            price=price,
@ -378,7 +394,7 @@ class OrderMode:
                'oid': oid,
            })

-        if order.price <= 0:
+        if float(order.price) <= 0:
            log.error(
                '*!? Invalid `Order.price <= 0` ?!*\n'
                # TODO: make this present multi-line in object form
@ -515,14 +531,15 @@ class OrderMode:
            # if an order msg is provided update the line
            # **from** that msg.
            if order:
-                if order.price <= 0:
+                price: float = float(order.price)
+                if price <= 0:
                    log.error(f'Order has 0 price, cancelling..\n{order}')
                    self.cancel_orders([order.oid])
                    return None

-                line.set_level(order.price)
+                line.set_level(price)
                self.on_level_change_update_next_order_info(
-                    level=order.price,
+                    level=price,
                    line=line,
                    order=order,
                    # use the corresponding position tracker for the
@ -681,9 +698,9 @@ class OrderMode:
    ) -> Dialog | None:
        # NOTE: the `.order` attr **must** be set with the
        # equivalent order msg in order to be loaded.
-        order = msg.req
+        order: Order = msg.req
        oid = str(msg.oid)
-        symbol = order.symbol
+        symbol: str = order.symbol

        # TODO: MEGA UGGG ZONEEEE!
        src = msg.src
@ -702,13 +719,22 @@ class OrderMode:
        order.oid = str(order.oid)
        order.brokers = [brokername]

-        # TODO: change this over to `MktPair`, but it's
-        # gonna be tough since we don't have any such data
-        # really in our clearing msg schema..
-        order.symbol = Symbol.from_fqme(
-            fqsn=fqme,
-            info={},
-        )
+        # ?TODO? change this over to `MktPair`, but it's gonna be
+        # tough since we don't have any such data really in our
+        # clearing msg schema..
+        # BUT WAIT! WHY do we even want/need this!?
+        #
+        # order.symbol = self.curr_mkt
+        #
+        # XXX, the old approach.. which i don't quire member why..
+        # -[ ] verify we for sure don't require this any more!
+        #  |_https://github.com/pikers/piker/issues/517
+        #
+        # order.symbol = Symbol.from_fqme(
+        #     fqsn=fqme,
+        #     info={},
+        # )
+
        maybe_dialog: Dialog | None = self.submit_order(
            send_msg=False,
            order=order,
@ -766,6 +792,7 @@ async def open_order_mode(
            brokerd_accounts,
            ems_dialog_msgs,
        ),
+        tractor.trionics.collapse_eg(),
        trio.open_nursery() as tn,

    ):
@ -1101,7 +1128,7 @@ async def process_trade_msg(
                        )
                    )
                ):
-                    msg.req = order
+                    msg.req: Order = order
                    dialog: (
                        Dialog
                        # NOTE: on an invalid order submission (eg.
@ -1166,7 +1193,7 @@ async def process_trade_msg(
            tm = time.time()
            mode.on_fill(
                oid,
-                price=req.price,
+                price=float(req.price),
                time_s=tm,
            )
            mode.lines.remove_line(uuid=oid)
@ -1221,7 +1248,7 @@ async def process_trade_msg(
            tm = details['broker_time']
            mode.on_fill(
                oid,
-                price=details['price'],
+                price=float(details['price']),
                time_s=tm,
                pointing='up' if action == 'buy' else 'down',
            )
--- a/pyproject.toml
+++ b/pyproject.toml
@ -23,7 +23,7 @@ name = "piker"
 version = "0.1.0a0dev0"
 description = "trading gear for hackers"
 authors = [{ name = "Tyler Goodlet", email = "goodboy_foss@protonmail.com" }]
-requires-python = ">=3.12, <3.13"
+requires-python = ">=3.12"
 license = "AGPL-3.0-or-later"
 readme = "README.rst"
 keywords = [
@ -39,8 +39,8 @@ classifiers = [
    "Operating System :: POSIX :: Linux",
    "Programming Language :: Python :: Implementation :: CPython",
    "Programming Language :: Python :: 3 :: Only",
-    "Programming Language :: Python :: 3.11",
    "Programming Language :: Python :: 3.12",
+    "Programming Language :: Python :: 3.13",
    "Intended Audience :: Financial and Insurance Industry",
    "Intended Audience :: Science/Research",
    "Intended Audience :: Developers",
@ -49,13 +49,13 @@ classifiers = [
 dependencies = [
    "async-generator >=1.10, <2.0.0",
    "attrs >=23.1.0, <24.0.0",
-    "bidict >=0.22.1, <0.23.0",
+    "bidict >=0.23.1",
    "colorama >=0.4.6, <0.5.0",
    "colorlog >=6.7.0, <7.0.0",
    "ib-insync >=0.9.86, <0.10.0",
-    "numba >=0.59.0, <0.60.0",
-    "numpy >=1.25, <2.0",
-    "polars >=0.18.13, <0.19.0",
+    "numpy>=2.0",
+    "polars >=0.20.6",
+    "polars-fuzzy-match>=0.1.5",
    "pygments >=2.16.1, <3.0.0",
    "rich >=13.5.2, <14.0.0",
    "tomli >=2.0.1, <3.0.0",
@ -63,21 +63,27 @@ dependencies = [
    "trio-util >=0.7.0, <0.8.0",
    "trio-websocket >=0.10.3, <0.11.0",
    "typer >=0.9.0, <1.0.0",
-    "rapidfuzz >=3.5.2, <4.0.0",
-    "pdbp >=1.5.0, <2.0.0",
-    "trio >=0.24, <0.25",
-    "pendulum >=3.0.0, <4.0.0",
+    "trio >=0.27",
+    "pendulum",
    "httpx >=0.27.0, <0.28.0",
    "cryptofeed >=2.4.0, <3.0.0",
-    "pyarrow >=17.0.0, <18.0.0",
+    "pyarrow>=18.0.0",
    "websockets ==12.0",
-    "msgspec",
+    "msgspec>=0.19.0,<0.20",
    "tractor",
-    "asyncvnc",
    "tomlkit",
+    "trio-typing>=0.10.0",
+    "numba>=0.61.0",
+    "pyvnc",
 ]
+# ------ dependencies ------

-[project.optional-dependencies]
+
+# TODO: add an `--only daemon` group for running non-ui / pikerd
+# service tree in distributed mode B)
+# https://docs.astral.sh/uv/concepts/projects/dependencies/#optional-dependencies
+
+[dependency-groups]
 uis = [
    # https://docs.astral.sh/uv/concepts/projects/dependencies/#optional-dependencies
    # TODO: make sure the levenshtein shit compiles on nix..
@ -90,12 +96,11 @@ uis = [
    # for consideration,
    # - 'visidata'

-    # TODO: add an `--only daemon` group for running non-ui / pikerd
-    # service tree in distributed mode B)
-    # https://docs.astral.sh/uv/concepts/projects/dependencies/#optional-dependencies
+    "qdarkstyle >=3.0.2, <4.0.0",
+    "pyqt6 >=6.7.0, <7.0.0",
+    "pyqtgraph",
 ]

-[dependency-groups]
 # TODO: a toolset that makes debugging a `pikerd` service (tree) easy
 # to hack on directly using more or less the local env:
 # - xonsh + xxh
@ -104,31 +109,92 @@ uis = [
 #
 # console ehancements and eventually remote debugging extras/helpers.
 # use `uv --dev` to enable
-dev = [
-    "pytest >=6.0.0, <7.0.0",
-    "elasticsearch >=8.9.0, <9.0.0",
-    "xonsh >=0.14.2, <0.15.0",
-    "prompt-toolkit ==3.0.40",
-    "cython >=3.0.0, <4.0.0",
+repl = [
+  # debug
+  "pdbp >=1.5.0, <2.0.0",
    "greenback >=1.1.1, <2.0.0",
-    "ruff>=0.9.6",
+  "xonsh",
+    "prompt-toolkit ==3.0.40",
+    "pyperclip>=1.9.0",
+
 ]
+testing = [
+  "pytest",
+]
+de = [
+  # DE-specific
+  "i3ipc>=2.2.1",
+]
+dev = [
+  # https://docs.astral.sh/uv/concepts/projects/dependencies/#development-dependencies
+  "cython >=3.0.0, <4.0.0",
+
+  # nested deps-groups
+  # https://docs.astral.sh/uv/concepts/projects/dependencies/#nesting-groups
+  {include-group = 'uis'},
+  {include-group = 'repl'},
+  {include-group = 'testing'},
+  {include-group = 'de'},
+]
+lint = [
+  # XXX, with flake.nix needs to be from nixpkgs
+  "ruff>=0.9.6" 
+  #
+  # ^TODO? these markers don't work; use deps-flags for now?
+  # ; os_name != 'nixos' and platform_system != 'NixOS'",
+  # ; defined('IN_NIX_SHELL')",
+]
+dbs = [
+  "elasticsearch >=8.9.0, <9.0.0",
+]
+# ------ dependency-groups ------
+
+
+[tool.pytest.ini_options]
+# https://docs.pytest.org/en/stable/reference/reference.html#configuration-options
+testpaths = [
+    "tests",
+]
+# https://docs.pytest.org/en/stable/reference/reference.html#confval-console_output_style
+console_output_style = 'progress'
+
+# https://docs.pytest.org/en/stable/how-to/plugins.html#disabling-plugins-from-autoloading
+# https://docs.pytest.org/en/stable/how-to/plugins.html#deactivating-unregistering-a-plugin-by-name
+addopts = '-p no:xonsh'
+# ------ tool.pytest ------
+

 [project.scripts]
 piker = "piker.cli:cli"
 pikerd = "piker.cli:pikerd"
 ledger = "piker.accounting.cli:ledger"
+# ------ project.scripts ------

 [tool.hatch.build.targets.sdist]
 include = ["piker"]
-
 [tool.hatch.build.targets.wheel]
 include = ["piker"]
+# ------ tool.hatch ------
+
+
+# TODO? move to a `uv.toml`?
+[tool.uv]
+python-preference = 'system'
+python-downloads = 'manual'
+# https://docs.astral.sh/uv/concepts/projects/dependencies/#default-groups
+default-groups = ['uis', 'dev']
+# ------ tool.uv ------
+

 [tool.uv.sources]
 pyqtgraph = { git = "https://github.com/pikers/pyqtgraph.git" }
-asyncvnc = { git = "https://github.com/pikers/asyncvnc.git", branch = "main" }
 tomlkit = { git = "https://github.com/pikers/tomlkit.git", branch ="piker_pin" }
-msgspec = { git = "https://github.com/jcrist/msgspec.git" }
-tractor = { git = "https://pikers.dev/goodboy/tractor", branch = "piker_pin" }
+pyvnc = { git = "https://github.com/regulad/pyvnc.git" }
+
+# XXX since, we're like, always hacking new shite all-the-time. Bp
+tractor = { git = "https://github.com/goodboy/tractor.git", branch ="piker_pin" }
+# tractor = { git = "https://pikers.dev/goodboy/tractor", branch = "piker_pin" }
+# tractor = { git = "https://pikers.dev/goodboy/tractor", branch = "main" }
+# ------ goodboy ------
+# hackin dev-envs, usually there's something new he's hackin in..
 # tractor = { path = "../tractor", editable = true }
--- a/ruff.toml
+++ b/ruff.toml
@ -62,8 +62,9 @@ ignore-init-module-imports = false
 fixable = ["ALL"]
 unfixable = []

+# TODO? uhh why no work!?
 # Allow unused variables when underscore-prefixed.
-dummy-variable-rgx = "^(_+|(_+[a-zA-Z0-9_]*[a-zA-Z0-9]+?))$"
+# dummy-variable-rgx = "^(_+|(_+[a-zA-Z0-9_]*[a-zA-Z0-9]+?))$"

 [format]
 # Use single quotes in `ruff format`.
--- a/1
+++ b/1
@ -0,0 +1 @@
+TAG_feed_status_update	./piker/data/feed.py	/TAG_feed_status_update/
--- a/tests/test_ems.py
+++ b/tests/test_ems.py
@ -179,7 +179,7 @@ def test_ems_err_on_bad_broker(
        # NOTE: emsd should error on the actor's enabled modules
        # import phase, when looking for a backend named `doggy`.
        except tractor.RemoteActorError as re:
-            assert re.type == ModuleNotFoundError
+            assert re.type is ModuleNotFoundError

    run_and_tollerate_cancels(load_bad_fqme)

--- a/tests/test_questrade.py
+++ b/tests/test_questrade.py
@ -142,7 +142,12 @@ async def test_concurrent_tokens_refresh(us_symbols, loglevel):
        # async with tractor.open_nursery() as n:
        #     await n.run_in_actor('other', intermittently_refresh_tokens)

-        async with trio.open_nursery() as n:
+        async with (
+            tractor.trionics.collapse_eg(),
+            trio.open_nursery(
+            # strict_exception_groups=False,
+            ) as n
+        ):

            quoter = await qt.stock_quoter(client, us_symbols)

@ -383,7 +388,9 @@ async def test_quote_streaming(tmx_symbols, loglevel, stream_what):
            else:
                symbols = [tmx_symbols]

-            async with trio.open_nursery() as n:
+            async with trio.open_nursery(
+                strict_exception_groups=False,
+            ) as n:
                for syms, func in zip(symbols, stream_what):
                    n.start_soon(func, feed, syms)

--- a/uv.lock
+++ b/uv.lock
Author	SHA1	Message	Date
Tyler Goodlet	2074eeea4f	Spurious first-draft of EG collapsing Topically, throughout various (seemingly) console-UX-affecting or benign spots in the code base; nothing that required more intervention beyond things superficial. A few spots also include `trio.Nursery` ref renames (always to something with a `tn` in it) and log-level reductions to quiet (benign) console noise oriented around issues meant to be solved long.. Note there's still a couple spots i left with the loose-ify flag because i haven't fully tested them without using the latest version of `tractor.trionics.collapse_eg()`, but more then likely they should flip over fine.	2026-01-02 18:22:11 -05:00
Tyler Goodlet	1799171705	Use `.trionics.collapse_eg()` in `.deribit.api` Commit this change separate from the (original) broader set applied to the entire code base since the `.deribit.api` mod contained changes from upstream max-pain work (from our very own @nt) which caused a noticeable conflict and intros un-required changes from his work to re-enable `deribit` support. Note the original commit, "69eac7bb Spurious first-draft of EG collapsing", applied similar changes through the rest of the code base. AGAIN, this mod's change is only being broken out to minimize upstream change conflicts due to updates to the `deribit` backend done earlier in time-history.	2026-01-02 18:22:11 -05:00
Tyler Goodlet	cffefac615	ib-related: cope with invalid txn timestamps That is inside embedded `.accounting.calc.dyn_parse_to_dt()` closure add an optional `_invalid: list` param to where we can report bad-timestamped records which we instead override and return as `from_timestamp(0.)` (when the parser loop falls through) and report later (in summary ) from the `.accounting.calc.iter_by_dt()` caller. Add some logging and an optional debug block for future tracing. NOTE, this commit was re-edited during a conflict between the orig branches: `dev/binance_api_3.1` & `dev/alt_tpts_for_perf`.	2026-01-02 18:19:50 -05:00
Tyler Goodlet	fc2d727fdb	Mk a `notes_to_self/` move orig file `ideas.rst'	2026-01-02 17:39:12 -05:00
Tyler Goodlet	05dde42f70	Drop old/masked ahab-docker daemon starting	2026-01-02 17:39:12 -05:00
Tyler Goodlet	04e423e6bd	Try running daemons on UDS tpt The root daemon, pikerd, needs to be adjusted to use diff default registry addrs to also utilize non-TCP, but for now this gets us started testing; so far so good B)	2026-01-02 17:37:55 -05:00
Tyler Goodlet	793a454463	Adjust feed status fields/display-pane to new actor-ID That is to use the new `tractor.msg.types.Aid` struct to pull the `brokerd` info from the `tractor.Channel.aid: Aid` attr as well as more generally handling the new `Channel.raddr.proto_key: str` and no longer assuming a TCP IPC transport; this per the recent `tractor.ipc` subsys which adds multi-IPC-transports! Downstream tweaks to match, - use an "opt-in" field set to display in the `brokerd` info pane in `.ui._feedstatus.mk_feed_label()`. \|_ also add some todos and drop some seemingly unneeded form sizing calcs? - tweak `.ui._label` to allow not using markdown, though ended up not doing that since it looked too plain..	2026-01-02 17:36:13 -05:00
Tyler Goodlet	b8b4f1b80f	Adjust to `trio`'s strict eg nurseries throughout! Using `tractor.trionics.collapse_eg()` as needed to avoid, at the least, crash-worthy (in debug-mode REPL-ing terms) nested cancellation egs that exhibit on SIGINT/ctl-c of each "app" (chart & daemon). Also a bit of renaming of all `trio.Nursery`s to `tn`, the new "task nursery" shorthand-var-name being used in all our other `tractor` related projects.	2026-01-02 17:36:13 -05:00
Tyler Goodlet	1cf041d8e6	Start a manual `tags` file for internal refs	2026-01-02 17:36:13 -05:00
Tyler Goodlet	831b6cfb21	Add a couple new grays to the pallete	2026-01-02 17:25:29 -05:00
Tyler Goodlet	e5f7e8de9d	Bump to (latest) `polars`, the `0.20.6x` series B) Since I was trying out the neat lookin `polars-fuzzy-match` (also added for now as a core dep here) which requires the new plugin sys, plus it's about time we synced with upstream! Adjust some column syntax to the new `.name` sub-field-space and the `uv` lock-file to match. Other, - add back `trio-typing` bc i guess something else needs it (debug tooling stuff in new `tractor`?) - flip back to the `tractor` pre-main pin since the new `main`-branch requires new `trio` stuff we haven't ported yet..	2026-01-02 17:24:17 -05:00
Tyler Goodlet	871bb2620e	Port to newer `tractor.get_registry()`	2026-01-02 17:00:23 -05:00
Tyler Goodlet	de980a69e0	Update legacy type to `tractor.MsgStream`	2026-01-02 17:00:23 -05:00
Tyler Goodlet	ab9f01caf2	Fix type-check assertion in ems test to use `is`	2026-01-02 17:00:23 -05:00
Tyler Goodlet	d85632ba9b	Cast to `float` as needed from order-mode and ems Since we're not quite yet using automatic typed msging from `tractor`/`msgspec` (i.e. still manually decoding order ctl msgs from built-in types..`dict`s still not `msgspec.Struct`) this adds the appropriate typecasting ops to ensure the required precision is attained prior to processing and/or submission to a brokerd backend service. For the `.clearing._ems`, - flip all `trigger_price` previously presumed to be `float` to just the field-identical `price: Decimal` and ensure we cast to `float` for any `trigger_price` usage, like before passing to `mk_check()`. For `.ui.order_mode.OrderMode`, - add a new `.curr_mkt: MktPair` convenience property to get the chart-active value. - ensure we always use the `.curr_mkt.quantize() -> Decimal` before setting any IPC-msg's `.price` field! - always cast `float(Order.price)` before use in setting line-levels. - don't bother setting `Order.symbol` to a (now fully removed) `Symbol` instance since it's not really required-for-use anywhere; leaving it a `str` (per the type-annot) is fine for now?	2026-01-02 17:00:23 -05:00
Tyler Goodlet	8294ca6487	Mk `Brokerd[Order].price` avoid `float`-errs By re-typing to a `.price: Decimal` field on both legs of the EMS. It seems we must do it ourselves since, - these msg's (fields) are relayed through the clearing engine to each `brokerd` backend and, - bc many (if not all) of those backends `.broker`-clients (nor their encapsulated "brokerage services") are not doing any precision-truncation themselves. So, for now, instead we opt to expect rounding at the source. This means we will explicitly require casting to/from `float` at the line-graphics interface to the order-clearing-engine (as implemented throughout `.ui.order_mode.OrderMode`); and this is coming shortly.	2026-01-02 17:00:23 -05:00
Tyler Goodlet	87385a4e2d	ib: never relay "Warning:" errors to EMS.. You'd think they could be bothered to make either a "log" or "warning" msg type instead of a `type='error'`.. but alas, this attempts to detect all such "warning"-errors and never proxy them to the clearing engine thus avoiding the cancellation of any associated (by `reqid`) pre-existing orders (control dialogs). Also update all surrounding log messages to a more multiline style.	2026-01-02 16:59:09 -05:00
Tyler Goodlet	b3c5478017	ib: jig `.data_reset_hack()` with vnc-client failover Since apparently porting to the new docker container enforces using a vnc password and `asyncvnc` seems to have a bug/mis-config whenever i've tried a pw over a wg tunnel..? Soo, this tries out the old `i3ipc`-win-focus + `xdo` click hack when the above fails. Deats, - add a mod-level `try_xdo_manual()` to wrap calling `i3ipc_xdotool_manual_click_hack()` with an oserr handler, ensure we don't bother trying if `i3ipc` import fails beforehand tho. - call ^ from both the orig case block and the failover from the vnc-client case. - factor the `+no_setup_msg: str` out to mod level and expect it to be `.format()`-ed. - refresh todo around `asyncvnc` pw ish.. - add a new `i3ipc_fin_wins_titled()` window-title scanner which predicates input `titles` and delivers any matches alongside the orig focused win at call time. - tweak `i3ipc_xdotool_manual_click_hack()` to call ^ and remove prior unfactored window scanning logic.	2026-01-02 16:59:09 -05:00
Tyler Goodlet	6c9a78c5a0	Add fix for binance API 3.1 rollout.. See https://developers.binance.com/docs/binance-spot-api-docs#2025-08-26	2026-01-02 16:59:09 -05:00
Tyler Goodlet	da223f7a55	kraken: add crash-handling around `Pair()` init Since it can otherwise be difficult to debug due to nursery cancellation (we need that taskman yo!).	2026-01-02 16:59:09 -05:00
Tyler Goodlet	49fe0a3398	kraken: `Pair.costmin` is now optional? Some pairs don't seem to define it but it's not listed as deprecated on official API page (new one now linked in type def's doc string).	2026-01-02 16:59:09 -05:00
Tyler Goodlet	29fc3b8a8b	binance: add new `permissionSets` to base `Pair`	2026-01-02 16:59:09 -05:00
Tyler Goodlet	1bfe777637	Update `binance` spot pairs with `amendAllowed` As per API updates, https://developers.binance.com/docs/binance-spot-api-docs https://developers.binance.com/docs/binance-spot-api-docs/faqs/order_amend_keep_priority I also slightly tweaked the filed mismatch exception note to include the `repr(pair_type)` so the dev can know which pair types should be changed.	2026-01-02 16:59:09 -05:00
Tyler Goodlet	c694d915f1	`.kraken`: add masked pauses for order req debug Such that the next time i inevitably must debug the some order-request error status or precision discrepancy, i have the mkt-symbol branch ready to go. Also, switch to `'action': 'buy'\|'sell' as action,` style `case` matching instead of the post-`if` predicate style.	2026-01-02 16:59:09 -05:00
Tyler Goodlet	c120cb51a4	`.questrade`: link in ws-API issue!	2026-01-02 16:59:09 -05:00
Tyler Goodlet	7c20231f16	`.kraken.broker`: need to `await verify_balances()` ..	2026-01-02 16:59:09 -05:00
Tyler Goodlet	d809c79788	`.brokers.ib.feed`: better `tractor.to_asyncio` typing and var naming throughout!	2026-01-02 16:59:09 -05:00
Tyler Goodlet	9f2f8a1664	`.brokers.cli`: module type and todo for `--pdb` flag to NOT src from sub-cmd	2026-01-02 16:59:09 -05:00
Tyler Goodlet	9f141635d1	Type loaded backend modules	2026-01-02 16:59:09 -05:00
Tyler Goodlet	0604ca7c82	Bump various `.brokers.core` doc string content/style	2026-01-02 16:59:09 -05:00
Tyler Goodlet	82c2256271	Add missing f-str prefix to log line	2026-01-02 16:55:15 -05:00
Tyler Goodlet	a743fa28b5	Teensie `piker.data` styling tweaks - use more compact optional value style with `\|`-union - fix `.flows` typing-only import since we need `MktPair` to be immediately defined for use on a `msgspec.Struct` field. - more "tree-like" warning msg in `.validate()` reporting.	2026-01-02 16:55:15 -05:00
Tyler Goodlet	07fbe859c3	Finally drop `Symbol` It was replaced by `MktPair` long ago in, https://github.com/pikers/piker/pull/489 with follow up for final removal in, https://github.com/pikers/piker/issues/517 Resolves #517	2026-01-02 16:49:16 -05:00
Tyler Goodlet	db0872e350	`.accounting._ledger`: typing anda more multiline styling	2026-01-02 16:49:16 -05:00
Tyler Goodlet	878002aee0	Drop some bps and style logic to multiline	2026-01-02 16:49:16 -05:00
Tyler Goodlet	c9e6510535	Invert `getattr()` check for `get_mkt_pairs()` ep Such that we `return` early when not defined by the provider backend to reduce an indent level in `SymbologyCache.load()`.	2026-01-02 16:49:16 -05:00
Tyler Goodlet	4cae3778c1	Allow ledger passes to ignore (symcache) unknown fqmes For example in the paper-eng, if you have a backend that doesn't fully support a symcache (yet) it's handy to be able to ignore processing other paper-eng txns when all you care about at the moment is the simulated symbol. NOTE, that currently this will still result in a key-error when you load more then one mkt with the paper engine (for which the backend does not have the symcache implemented) since no fqme ad-hoc query was made for the 2nd symbol (and i'm not sure we should support that kinda hackery over just encouraging the sym-cache being added?). Def needs a little more thought depending on how many backends are never going to be able to (easily) support caching..	2026-01-02 16:49:16 -05:00
Gud Boi	ff49ff0376	Merge pull request 'wayland_nix_py313: keeping up with modern DEs and nix(os)' (#53 ) from wayland_nix_py313 into main Submitted-in: https://www.pikers.dev/pikers/piker/pulls/53	2026-01-02 21:47:40 +00:00
Tyler Goodlet	b884febd5f	Update readme with `nix develop`/flake usage on wayland, and tweaked `uv sync` cmds	2026-01-02 14:07:56 -05:00
Tyler Goodlet	291508a9b1	Fix readme to `uv sync`.. link to astral docs	2026-01-02 14:01:49 -05:00
Tyler Goodlet	7498c221a8	Drop variable regex from `ruff.toml` Same as in other projects, seems to be not parsing and causing `ruff` to crash?!?	2026-01-02 12:38:36 -05:00
Tyler Goodlet	64828d2fe1	Bump `uv.lock` on nixos Namely from `pyproject.toml` re-org of dep-groups.	2026-01-02 12:38:19 -05:00
Tyler Goodlet	1e6fa8675d	A better dep-groups specificity breakdown Trying to start organizing non-hard deps into groups with sensible "domain names" as it were. I coulda sworn we originally had at least UI libs setup this way.. musta got lost in prior nix(os) porting. Specifics, - move all Qt and `rapidfuzz` deps into the `uis` group. - add a new `repl` group for all the `pdbp` (debugging utils) and `xonsh` (@goodboy's shell pref) related console related extensions. - add a `testing` group for the harness' needs. - add a `de` for (as of rn) TWM specific libs. - nest all the new ^ groups in the `dev` group as needed.	2026-01-02 12:37:49 -05:00
Tyler Goodlet	51fb871f57	Skip `ruff` dev-dep on nix(os) overlays Since the linking will be borked if we pull the wheel using `uv`; we need to instead delegate to the `nixpkgs` version in the dev-shell. `pyrpoject` deats, - add a new deps-group: 'lint' which contains `ruff`. - drop `ruff` from std deps (not sure how it got there anyway). - mv `elasticsearch` to a new `dbs` deps group (we don't really even want to be using it in the near furure). - mv `uis` group into dep-groups section from `project.optionals-deps`. - add a `tool.uv.default-groups = ['uis', 'dev']` setting which then will avoid install of any non-explicit extras. - put `rapidfuzz` only in `uis` group. `flake.nix` tweaks, - include `ruff` and `pypkgs.ruff` in the overlay. - pass `--no-group ruff` to the `uv sync` line of shell init.	2026-01-02 12:36:39 -05:00
Tyler Goodlet	ffd6438b88	Add bash-completion pkgs to flake overlay Mks completions work inside custom embedded shells (like `xonsh`!).	2026-01-02 12:36:33 -05:00
Tyler Goodlet	5449141ec4	Update `default.nix` (from @nt) for py313	2026-01-02 12:36:19 -05:00
Tyler Goodlet	5337f8abee	nix: make Qt6 work on wayland Taking many tips from our `default.nix` (thanks @nt!) this seems to be the minimal overlay required for a flake to get up and running with `piker chart` B) Notes, - for now, we're pinning to a major `cpython` version (3.13) - ensure we (can) build with `nixpkgs.qt6.qtwayland` - add the minimal Qt ld-lib-path linkings including those for plugin use (required for wayland mode). - for now, hardcode "wayland" platform-mode and the linux standard "xdg-shell" integration. - leave some TODOs to better parameterize around py versions.	2026-01-02 12:36:12 -05:00
Tyler Goodlet	0329a6d852	Bump `flake.lock`, seemly nicely minimized B)	2026-01-02 12:36:05 -05:00
Tyler Goodlet	ff045f699f	Redo `flake.nix` using `pyproject.nix` recos Particularly using their recommended "impure template", - https://pyproject-nix.github.io/pyproject.nix/templates.html#impure - code: https://github.com/pyproject-nix/pyproject.nix/blob/master/templates/impure/flake.nix Note the `shellHook` now contains various `uv`-specific osenv settings and cmds to get a dev-env setup the way i would do it by default, that includes all dev and extra (group) deps. For now i've hard coded the "virt-env subdir" used by `uv` to match the cpython version. We can obviously parameterize this much better in the future. For those who want to spawn a diff shell then bash see the commented line, for ex. i personally use `nix develop -c uv run xonsh`.	2026-01-02 12:35:59 -05:00
Tyler Goodlet	6d6ca1a908	Don't pin `pendulum` version so we can use wheel Bump version in lock file to match.	2026-01-02 12:35:44 -05:00
				`@ -0,0 +1 @@`
				`TAG_feed_status_update ./piker/data/feed.py /TAG_feed_status_update/`