Code

Agg feedz#414

Code

Merged

goodboy merged 49 commits intomasterpikers/piker:masterfrom agg_feedzpikers/piker:agg_feedzCopy head branch name to clipboardJan 13, 2023

+1,321-753

Commits

Commits on Jan 10, 2023

• Only log pos size errors for ib

  goodboy

  committed
  4000034

  Copy full SHA for 4000034

• Drop duplicate live gateway from compose file for now

  goodboy

  committed
  508de61

  Copy full SHA for 508de61

• Always set fqsn in Feed.symbols: dict

  goodboy

  committed
  344a634

  Copy full SHA for 344a634

• Make all UI entrypoints accept an fqsn list

  Show description for 2a9042b
  goodboy

  committed
  2a9042b

  Copy full SHA for 2a9042b

• Use new GodWidget.load_symbols() from search

  goodboy

  committed
  8e85ed9

  Copy full SHA for 8e85ed9

• EMS: expect fqsn key in Feed.symbols

  goodboy

  committed
  051a872

  Copy full SHA for 051a872

• Drop tractor.log level override fixture

  goodboy

  committed
  1bf1965

  Copy full SHA for 1bf1965

• Start data feed layer test suite

  Show description for c7d5db5
  goodboy

  committed
  c7d5db5

  Copy full SHA for c7d5db5

• Just warn on ib symbol search lags

  goodboy

  committed
  5bf3cb8

  Copy full SHA for 5bf3cb8

• First draft aggregate feedz support

  Show description for 18dc8b0
  goodboy

  committed
  18dc8b0

  Copy full SHA for 18dc8b0

• Add Symbol.fqsn: str property

  goodboy

  committed
  e7de540

  Copy full SHA for e7de540

• Expect init startup quotes from each symbol

  goodboy

  committed
  32b36aa

  Copy full SHA for 32b36aa

• Use new |-union style type annots in sampling routines

  goodboy

  committed
  25bfe6f

  Copy full SHA for 25bfe6f

• Further feed syncing fixes wrt to Flumes

  Show description for bb6452b
  goodboy

  committed
  bb6452b

  Copy full SHA for bb6452b

• Make Symbol derive from internal .types.Struct

  goodboy

  committed
  7daab63

  Copy full SHA for 7daab63

• Adjust to per-fqsn-oriented Flume lookups throughout

  goodboy

  committed
  2c4daf0

  Copy full SHA for 2c4daf0

• Fix broker-tail stripping using str.removesuffix()

  goodboy

  committed
  8a01c9e

  Copy full SHA for 8a01c9e

• Port storesh cli-cmd machinery to Flume apis

  goodboy

  committed
  29b6b3e

  Copy full SHA for 29b6b3e

• Add kraken test, ensure single broker-provider for now

  goodboy

  committed
  36868bb

  Copy full SHA for 36868bb

• Fix partial-frame-missing backfill logic

  Show description for 8476d8d
  goodboy

  committed
  8476d8d

  Copy full SHA for 8476d8d

• Just drop the pretty repr from our struct for now

  goodboy

  committed
  d6fb6fe

  Copy full SHA for d6fb6fe

• Finally fix tsdb -> shm backfill loading

  Show description for 81516c5
  goodboy

  committed
  81516c5

  Copy full SHA for 81516c5

• Storage.read_ohlcv() now returns a numpy array

  goodboy

  committed
  20a3962

  Copy full SHA for 20a3962

• Multi-broker quotes with Feed.open_multi_stream()

  Show description for 7b9db86
  goodboy

  committed
  7b9db86

  Copy full SHA for 7b9db86

• Unpack broker mod and portal from fqsn for brokerd-trade-dialogs

  goodboy

  committed
  7bbe86d

  Copy full SHA for 7bbe86d

• Add multi-broker streaming test using both binance and kraken

  goodboy

  committed
  e348968

  Copy full SHA for e348968

• Not all accounts will have API trade transactions this session..

  goodboy

  committed
  0a959c1

  Copy full SHA for 0a959c1

• Use (a new) piker_pin branch in tractor (again)

  goodboy

  committed
  ddbba76

  Copy full SHA for ddbba76

• Add an sdist job to CI

  goodboy

  committed
  79fcbcc

  Copy full SHA for 79fcbcc

• Always touch config file dir if dne

  goodboy

  committed
  c088963

  Copy full SHA for c088963

• Move maybe_open_feed() above for readability

  goodboy

  committed
  1e96ca3

  Copy full SHA for 1e96ca3

• Ensure correct stream is set on each Flume

  Show description for f5cd63a
  goodboy

  committed
  f5cd63a

  Copy full SHA for f5cd63a

• Catch overruns on throttled feed subs too

  Show description for 326f153
  goodboy

  committed
  326f153

  Copy full SHA for 326f153

• Set brokers: list[st] from mods when not provided..

  goodboy

  committed
  88870fd

  Copy full SHA for 88870fd

• Rework _FeedsBus subscriptions mgmt using set

  Show description for 2a158ae
  goodboy

  committed
  2a158ae

  Copy full SHA for 2a158ae

• Adjust built-in backend list to known working

  goodboy

  committed
  967e28b

  Copy full SHA for 967e28b

• Revert "Fix _main() arg back to sym: str"

  Show description for c944db5
  goodboy

  committed
  c944db5

  Copy full SHA for c944db5

• Only require -b <brokername> for filtering

  Show description for 28fd795
  goodboy

  committed
  28fd795

  Copy full SHA for 28fd795

• Bump up timeout on multi-feed test for CI

  goodboy

  committed
  5d021ff

  Copy full SHA for 5d021ff

• Use ETH on kraken to ensure enough quotes

  goodboy

  committed
  b7e1443

  Copy full SHA for b7e1443

• Add ci_env detector fixture

  goodboy

  committed
  f232d6d

  Copy full SHA for f232d6d

• Always force lowercase on binance symbol keys

  Show description for 76f920a
  goodboy

  committed
  76f920a

  Copy full SHA for 76f920a

• binance: always request an extra 1min OHLC bar

  Show description for f6b7057
  goodboy

  committed
  f6b7057

  Copy full SHA for f6b7057

• Set global registry addr after first entry point spawns pikerd

  goodboy

  committed
  81585d9

  Copy full SHA for 81585d9

• Reset ._registry_addr to any passed in value from caller

  goodboy

  committed
  008ae47

  Copy full SHA for 008ae47

• Add a open_test_pikerd() acm fixture for easy booting of the service stack

  goodboy

  committed
  0662210

  Copy full SHA for 0662210

• Only run kraken feed tests in CI, use open_test_pikerd()

  goodboy

  committed
  593db0e

  Copy full SHA for 593db0e

• Adjust cli mod imports of daemon sockaddr vars

  goodboy

  committed
  55de9ab

  Copy full SHA for 55de9ab

• Go back to Feed.pause/resume(), new flume APIs coming later

  goodboy

  committed
  963e5bd

  Copy full SHA for 963e5bd