|_TCPAddress[('127.0.0.1', 55355)]

'MsgpackTCPStream' already closed by peer
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 222, in _iter_packets
    header: bytes = await self.recv_stream.receive_exactly(4)
                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 107, in receive_exactly
    data = await self.receive(num_bytes)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 53, in receive
    data = await self.transport_stream.receive_some(to_receive)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 140, in receive_some
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 43, in _translate_socket_errors_to_stream_errors
    raise trio.BrokenResourceError(f"socket connection broken: {exc}") from exc

    socket connection broken: [WinError 10054] An existing connection was forcibly closed by the remote host

Oct 08 14:10:53 (brokerd.binance[206681], 8832, trio._highlevel_serve_listeners._run_handler[533664])) [WARNING] tractor _exceptions.py:995 peer IPC channel closed abruptly?   

<=x[
  <Channel(
 |_status: 'connected'
 |_peer: 'chart@17084'
 |_msgstream: MsgpackTCPStream
   maddr: '/ipv4/127.0.0.1/tcp/62856'
   proto: 'tcp'
   layer: 4
   codec: 'msgpack'
   .laddr=TCPAddress[('127.0.0.1', 62802)]
   .raddr=TCPAddress[('127.0.0.1', 62856)]
)>

  |_TCPAddress[('127.0.0.1', 62856)]

'MsgpackTCPStream' already closed by peer
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 222, in _iter_packets
    header: bytes = await self.recv_stream.receive_exactly(4)
                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 107, in receive_exactly
    data = await self.receive(num_bytes)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 53, in receive
    data = await self.transport_stream.receive_some(to_receive)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 140, in receive_some
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 43, in _translate_socket_errors_to_stream_errors
    raise trio.BrokenResourceError(f"socket connection broken: {exc}") from exc

    socket connection broken: [WinError 10054] An existing connection was forcibly closed by the remote host

Oct 08 14:10:53 (samplerd[86ab06], 10040, trio._highlevel_serve_listeners._run_handler[746672])) [WARNING] tractor _exceptions.py:995 peer IPC channel closed abruptly?

<=x[
  <Channel(
 |_status: 'connected'
 |_peer: 'chart@17084'
 |_msgstream: MsgpackTCPStream
   maddr: '/ipv4/127.0.0.1/tcp/62877'
   proto: 'tcp'
   layer: 4
   codec: 'msgpack'
   .laddr=TCPAddress[('127.0.0.1', 62822)]
   .raddr=TCPAddress[('127.0.0.1', 62877)]
)>

  |_TCPAddress[('127.0.0.1', 62877)]

'MsgpackTCPStream' already closed by peer
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 222, in _iter_packets
    header: bytes = await self.recv_stream.receive_exactly(4)
                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 107, in receive_exactly
    data = await self.receive(num_bytes)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 53, in receive
    data = await self.transport_stream.receive_some(to_receive)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 140, in receive_some
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 43, in _translate_socket_errors_to_stream_errors
    raise trio.BrokenResourceError(f"socket connection broken: {exc}") from exc

    socket connection broken: [WinError 10054] An existing connection was forcibly closed by the remote host

Oct 08 14:11:22 (brokerd.binance[206681], 8832, piker.data._web_bs._reconnect_forever.<locals>.proxy_msgs[528032])) [ERROR] piker _web_bs.py:203 functools
WS feed seems down and slow af.. reconnecting

Oct 08 14:11:22 (brokerd.binance[206681], 8832, piker.data._web_bs._reconnect_forever[526096])) [ERROR] piker _web_bs.py:291 Reconnect-attempt failed ??

  + Exception Group Traceback (most recent call last):
  |   File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 245, in _reconnect_forever
  |     open_websocket_url(url) as ws,
  |     ^^^^^^^^^^^^^^^^^^^^^^^
  |   File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 217, in __aexit__
  |     await anext(self.gen)
  |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 114, in open_websocket
  |     async with trio.open_nursery() as new_nursery:
  |                ^^^^^^^^^^^^^^^^^^^
  |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1058, in __aexit__
  |     raise combined_error_from_nursery
  | ExceptionGroup: Exceptions from Trio nursery (1 sub-exception)
  +-+---------------- 1 ----------------
    | Traceback (most recent call last):
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1222, in _reader_task
    |     await handler(event)
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1161, in _handle_ping_event
    |     await self._send(event.response())
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1266, in _send
    |     data = self._wsproto.send(event)
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\wsproto\__init__.py", line 64, in send
    |     data += self.connection.send(event)
    |             ^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\wsproto\connection.py", line 107, in send
    |     raise LocalProtocolError(
    | wsproto.utilities.LocalProtocolError: Event Pong(payload=bytearray(b'1759947024158')) cannot be sent in state ConnectionState.LOCAL_CLOSING.
    +------------------------------------
Oct 08 14:11:22 (brokerd.binance[206681], 8832, piker.data.feed.allocate_persistent_feed[533488])) [WARNING] piker feed.py:454 btcusdt.spot.binance feed task terminated        
Oct 08 14:11:22 (brokerd.binance[206681], 8832, piker.data._web_bs._reconnect_forever[534016])) [ERROR] piker _web_bs.py:291 Reconnect-attempt failed ??

  + Exception Group Traceback (most recent call last):
  |   File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 245, in _reconnect_forever
  |     open_websocket_url(url) as ws,
  |     ^^^^^^^^^^^^^^^^^^^^^^^
  |   File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
  |     await self.gen.athrow(value)
  |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 114, in open_websocket
  |     async with trio.open_nursery() as new_nursery:
  |                ^^^^^^^^^^^^^^^^^^^
  |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1058, in __aexit__
  |     raise combined_error_from_nursery
  | BaseExceptionGroup: Exceptions from Trio nursery (2 sub-exceptions)
  +-+---------------- 1 ----------------
    | Traceback (most recent call last):
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1232, in _reader_task
    |     data = await self._stream.receive_some(RECEIVE_BYTES)
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_ssl.py", line 721, in receive_some
    |     received = await self._retry(self._ssl_object.read, max_bytes)
    |                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_ssl.py", line 626, in _retry
    |     data = await self.transport_stream.receive_some()
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 141, in receive_some
    |     return await self.socket.recv(max_bytes)
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_socket.py", line 436, in wrapper
    |     return await self._nonblocking_helper(wait_fn, fn, *args, **kwargs)
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_socket.py", line 1013, in _nonblocking_helper
    |     await wait_fn(self._sock)
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_generated_io_windows.py", line 61, in wait_readable
    |     return await GLOBAL_RUN_CONTEXT.runner.io_manager.wait_readable(sock)
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_io_windows.py", line 785, in wait_readable
    |     await self._afd_poll(sock, "read_task")
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_io_windows.py", line 760, in _afd_poll
    |     await _core.wait_task_rescheduled(abort_fn)
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_traps.py", line 208, in wait_task_rescheduled
    |     return (await _async_yield(WaitTaskRescheduled(abort_func))).unwrap()
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\outcome\_impl.py", line 213, in unwrap
    |     raise captured_error
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1567, in raise_cancel
    |     raise Cancelled._create()
    | trio.Cancelled: Cancelled
    |
    | During handling of the above exception, another exception occurred:
    |
    | Traceback (most recent call last):
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1213, in _reader_task
    |     async with self._send_channel:
    |                ^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_abc.py", line 309, in __aexit__
    |     await self.aclose()
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_channel.py", line 289, in aclose
    |     await trio.lowlevel.checkpoint()
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 2918, in checkpoint
    |     await _core.wait_task_rescheduled(lambda _: _core.Abort.SUCCEEDED)
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_traps.py", line 208, in wait_task_rescheduled
    |     return (await _async_yield(WaitTaskRescheduled(abort_func))).unwrap()
    |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\outcome\_impl.py", line 213, in unwrap
    |     raise captured_error
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1567, in raise_cancel
    |     raise Cancelled._create()
    | trio.Cancelled: Cancelled
    +---------------- 2 ----------------
    | Exception Group Traceback (most recent call last):
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 127, in open_websocket
    |     yield connection
    |   File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 247, in _reconnect_forever
    |     trio.open_nursery() as tn,
    |     ^^^^^^^^^^^^^^^^^^^
    |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1058, in __aexit__
    |     raise combined_error_from_nursery
    | BaseExceptionGroup: Exceptions from Trio nursery (3 sub-exceptions)
    +-+---------------- 1 ----------------
      | Traceback (most recent call last):
      |   File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 280, in _reconnect_forever
      |     await trio.sleep_forever()
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_timeouts.py", line 71, in sleep_forever
      |     await trio.lowlevel.wait_task_rescheduled(lambda _: trio.lowlevel.Abort.SUCCEEDED)
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_traps.py", line 208, in wait_task_rescheduled
      |     return (await _async_yield(WaitTaskRescheduled(abort_func))).unwrap()       
      |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^       
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\outcome\_impl.py", line 213, in unwrap
      |     raise captured_error
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1567, in raise_cancel
      |     raise Cancelled._create()
      | trio.Cancelled: Cancelled
      +---------------- 2 ----------------
      | Traceback (most recent call last):
      |   File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 225, in open_fixture
      |     await trio.sleep_forever()
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_timeouts.py", line 71, in sleep_forever
      |     await trio.lowlevel.wait_task_rescheduled(lambda _: trio.lowlevel.Abort.SUCCEEDED)
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_traps.py", line 208, in wait_task_rescheduled
      |     return (await _async_yield(WaitTaskRescheduled(abort_func))).unwrap()       
      |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^       
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\outcome\_impl.py", line 213, in unwrap
      |     raise captured_error
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1567, in raise_cancel
      |     raise Cancelled._create()
      | trio.Cancelled: Cancelled
      +---------------- 3 ----------------
      | Traceback (most recent call last):
      |   File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 187, in proxy_msgs
      |     msg: Any = await ws.get_message()
      |                ^^^^^^^^^^^^^^^^^^^^^^
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 887, in get_message
      |     message = await self._recv_channel.receive()
      |               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_channel.py", line 341, in receive
      |     await trio.lowlevel.checkpoint_if_cancelled()
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 2940, in checkpoint_if_cancelled
      |     await _core.checkpoint()
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 2918, in checkpoint
      |     await _core.wait_task_rescheduled(lambda _: _core.Abort.SUCCEEDED)
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_traps.py", line 208, in wait_task_rescheduled
      |     return (await _async_yield(WaitTaskRescheduled(abort_func))).unwrap()       
      |            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^       
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\outcome\_impl.py", line 213, in unwrap
      |     raise captured_error
      |   File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 1567, in raise_cancel
      |     raise Cancelled._create()
      | trio.Cancelled: Cancelled
      +------------------------------------
Oct 08 14:11:22 (brokerd.binance[206681], 8832, piker.brokers.binance.feed.stream_quotes[533840])) [WARNING] tractor.trionics _taskc.py:257 
^^WARNING^^
the above <class 'BaseExceptionGroup'> was masked by a <class 'trio.Cancelled'>

This can occurr when,

 - a `trio.Nursery/CancelScope` embeds a `finally/except:`-block which execs an un-shielded checkpoint!

Oct 08 14:11:23 (brokerd.binance[206681], 8832, _setup_persistent_brokerd[523632])) [ERROR] tractor _rpc.py:899 IPC context terminated 

after having 'errored'

LocalProtocolError("Event Pong(payload=bytearray(b'1759947024158')) cannot be sent in state ConnectionState.LOCAL_CLOSING.")
Traceback (most recent call last):
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 838, in _invoke
    raise scope_err
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 664, in _invoke
    collapse_eg(hide_tb=False),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 684, in _invoke
    res: Any|PayloadT = await coro
                        ^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\piker\brokers\_daemon.py", line 100, in _setup_persistent_brokerd
    tractor.trionics.collapse_eg(),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\piker\brokers\binance\feed.py", line 484, in stream_quotes
    open_autorecon_ws(
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 355, in open_autorecon_ws
    tractor.trionics.collapse_eg(),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1222, in _reader_task
    await handler(event)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1161, in _handle_ping_event
    await self._send(event.response())
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1266, in _send
    data = self._wsproto.send(event)
           ^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\wsproto\__init__.py", line 64, in send
    data += self.connection.send(event)
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\wsproto\connection.py", line 107, in send
    raise LocalProtocolError(
wsproto.utilities.LocalProtocolError: Event Pong(payload=bytearray(b'1759947024158')) cannot be sent in state ConnectionState.LOCAL_CLOSING.
( ^^^ this exc was collapsed from a group ^^^ )




Oct 08 14:11:23 (brokerd.binance[206681], 8832, _setup_persistent_brokerd[523632])) [ERROR] tractor _rpc.py:365 RPC task crashed
|_<Context(
 |_ipc: /ipv4/127.0.0.1/tcp/6116
   uid='Aid(
  name: str = 'pikerd',
  uuid: str = 'a49d7c5d-89eb-4441-82c7-ab9acc8b0ed8',
  pid: int|None = 53180,
)'
   cid='f504bff3-47d6-414f-ba18-9c61236eb4f9'

 |_rpc: piker.brokers._daemon:_setup_persistent_brokerd() -> LocalProtocolError
   side='child'
   <Task '_setup_persistent_brokerd' at 0x27fcaccd4f0>

 |_state: 'errored'
   outcome=Event Pong(payload=bytearray(b'1759947024158')) cannot be sent in state ConnectionState.LOCAL_CLOSING.
   result=<class 'tractor._context.Unresolved'>
   cancel_called=False
   cancel_acked=False
   canceller=None
None)>

Traceback (most recent call last):
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 285, in _errors_relayed_via_ipc
    yield  # run RPC invoke body
    ^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 838, in _invoke
    raise scope_err
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 664, in _invoke
    collapse_eg(hide_tb=False),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 684, in _invoke
    res: Any|PayloadT = await coro
                        ^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\piker\brokers\_daemon.py", line 100, in _setup_persistent_brokerd
    tractor.trionics.collapse_eg(),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\piker\brokers\binance\feed.py", line 484, in stream_quotes
    open_autorecon_ws(
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\piker\data\_web_bs.py", line 355, in open_autorecon_ws
    tractor.trionics.collapse_eg(),
    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1222, in _reader_task
    await handler(event)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1161, in _handle_ping_event
    await self._send(event.response())
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio_websocket\_impl.py", line 1266, in _send
    data = self._wsproto.send(event)
           ^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\wsproto\__init__.py", line 64, in send
    data += self.connection.send(event)
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\wsproto\connection.py", line 107, in send
    raise LocalProtocolError(
wsproto.utilities.LocalProtocolError: Event Pong(payload=bytearray(b'1759947024158')) cannot be sent in state ConnectionState.LOCAL_CLOSING.
( ^^^ this exc was collapsed from a group ^^^ )

Oct 08 14:11:23 (pikerd[a49d7c], 53180, trio._highlevel_serve_listeners._run_handler[627984])) [ERROR] tractor _rpc.py:1364 Actor errored:
Traceback (most recent call last):
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 1056, in process_messages
    await actor._deliver_ctx_payload(
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_runtime.py", line 646, in _deliver_ctx_payload
    return await ctx._deliver_msg(msg)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_context.py", line 1844, in _deliver_msg
    f'{pformat(re)}\n'
       ^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 62, in pformat
    underscore_numbers=underscore_numbers).pformat(object)
                                           ^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 161, in pformat
    self._format(object, sio, 0, 0, {}, 0)
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 178, in _format
    rep = self._repr(object, context, level)
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 458, in _repr
    repr, readable, recursive = self.format(object, context.copy(),
                                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 471, in format
    return self._safe_repr(object, context, maxlevels, level)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 632, in _safe_repr
    rep = repr(object)
          ^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 627, in pformat
    fields: str = self._mk_fields_str(
                  ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 524, in _mk_fields_str
    and not self.is_inception()
            ^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 591, in is_inception
    self.src_type
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 427, in src_type
    raise TypeError(
TypeError: Failed to lookup src error type with `tractor._exceptions.get_err_type()` :  
LocalProtocolError
Oct 08 14:11:23 (pikerd[a49d7c], 53180, tractor._runtime.async_main[141968])) [ERROR] tractor _runtime.py:1727 Main actor-runtime task errored
<x)
 |_<Arbiter(
 |_id: 'pikerd@53180'
 |_ipc: 'server-shutdown'
 |_rpc: 0 active tasks
 |_state: 'running'
   task: tractor._runtime.async_main
   loglevel: 'WARNING'
   subactors_spawned: 3
)>


Traceback (most recent call last):
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_runtime.py", line 1548, in async_main
    collapse_eg(),
    ^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_serve_listeners.py", line 34, in _run_handler
    await handler(stream)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_server.py", line 456, in handle_stream_from_peer
    ) = await _rpc.process_messages(
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 1056, in process_messages
    await actor._deliver_ctx_payload(
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_runtime.py", line 646, in _deliver_ctx_payload
    return await ctx._deliver_msg(msg)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_context.py", line 1844, in _deliver_msg
    f'{pformat(re)}\n'
       ^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 62, in pformat
    underscore_numbers=underscore_numbers).pformat(object)
                                           ^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 161, in pformat
    self._format(object, sio, 0, 0, {}, 0)
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 178, in _format
    rep = self._repr(object, context, level)
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 458, in _repr
    repr, readable, recursive = self.format(object, context.copy(),
                                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 471, in format
    return self._safe_repr(object, context, maxlevels, level)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 632, in _safe_repr
    rep = repr(object)
          ^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 627, in pformat
    fields: str = self._mk_fields_str(
                  ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 524, in _mk_fields_str
    and not self.is_inception()
            ^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 591, in is_inception
    self.src_type
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 427, in src_type
    raise TypeError(
TypeError: Failed to lookup src error type with `tractor._exceptions.get_err_type()` :  
LocalProtocolError
( ^^^ this exc was collapsed from a group ^^^ )

Oct 08 14:11:23 (pikerd[a49d7c], 53180, piker.service._mngr.Services.start_service_task.<locals>.open_context_in_task[633968])) [ERROR] tractor.ipc _transport.py:482 'MsgpackTCPStream' layer failed pre-send ??

Traceback (most recent call last):
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 430, in send
    return await self.stream.send_all(size + bytes_data)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 105, in send_all
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 41, in _translate_socket_errors_to_stream_errors
    raise trio.ClosedResourceError("this socket was already closed") from None
trio.ClosedResourceError: this socket was already closed
Oct 08 14:11:23 (pikerd[a49d7c], 53180, piker.service._mngr.Services.start_service_task.<locals>.open_context_in_task[633968])) [WARNING] tractor _context.py:2433 IPC connection for context is broken?
task: a031f0dc-d323-48ad-b9ed-cb30f34c1028
actor: ('samplerd', '86ab0690-2d91-4be7-995a-83421a4cea81')
Oct 08 14:11:23 (pikerd[a49d7c], 53180, piker.service._mngr.Services.start_service_task.<locals>.open_context_in_task[628336])) [ERROR] tractor.ipc _transport.py:482 'MsgpackTCPStream' layer failed pre-send ??

Traceback (most recent call last):
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 430, in send
    return await self.stream.send_all(size + bytes_data)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 105, in send_all
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 41, in _translate_socket_errors_to_stream_errors
    raise trio.ClosedResourceError("this socket was already closed") from None
trio.ClosedResourceError: this socket was already closed
Oct 08 14:11:23 (pikerd[a49d7c], 53180, piker.service._mngr.Services.start_service_task.<locals>.open_context_in_task[628336])) [WARNING] tractor _context.py:2433 IPC connection for context is broken?
task: f504bff3-47d6-414f-ba18-9c61236eb4f9
actor: ('brokerd.binance', '20668161-7b71-4ba8-aa27-005be44032a1')
Oct 08 14:11:23 (pikerd[a49d7c], 53180, piker.service._mngr.Services.start_service_task.<locals>.open_context_in_task[934784])) [ERROR] tractor.ipc _transport.py:482 'MsgpackTCPStream' layer failed pre-send ??

Traceback (most recent call last):
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 430, in send
    return await self.stream.send_all(size + bytes_data)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 105, in send_all
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 41, in _translate_socket_errors_to_stream_errors
    raise trio.ClosedResourceError("this socket was already closed") from None
trio.ClosedResourceError: this socket was already closed
Oct 08 14:11:23 (pikerd[a49d7c], 53180, piker.service._mngr.Services.start_service_task.<locals>.open_context_in_task[934784])) [WARNING] tractor _context.py:2433 IPC connection for context is broken?
task: ce6ab247-a951-4988-9ef1-fdd447b85ee3
actor: ('emsd', '193ebeda-8743-4f72-9592-e0076892315a')
Oct 08 14:11:23 (pikerd[a49d7c], 53180, tractor._spawn.new_proc[933200])) [WARNING] tractor _spawn.py:400 Subactor still alive after cancel request?

uid: Aid(
  name: str = 'emsd',
  uuid: str = '193ebeda-8743-4f72-9592-e0076892315a',
  pid: int|None = 38968,
)
|_<trio.Process ['C:\\Users\\austi\\Documents\\Code\\piker\\piker\\.venv\\Scripts\\python.exe', '-m', 'tractor._child', '--uid', "('emsd', '193ebeda-8743-4f72-9592-e0076892315a')", '--parent_addr', "('127.0.0.1', 6116)", '--loglevel', 'warning']: running with PID 14480>

Oct 08 14:11:23 (pikerd[a49d7c], 53180, tractor._spawn.new_proc[625344])) [WARNING] tractor _spawn.py:400 Subactor still alive after cancel request?

uid: Aid(
  name: str = 'brokerd.binance',
  uuid: str = '20668161-7b71-4ba8-aa27-005be44032a1',
  pid: int|None = 8832,
)
|_<trio.Process ['C:\\Users\\austi\\Documents\\Code\\piker\\piker\\.venv\\Scripts\\python.exe', '-m', 'tractor._child', '--uid', "('brokerd.binance', '20668161-7b71-4ba8-aa27-005be44032a1')", '--parent_addr', "('127.0.0.1', 6116)", '--loglevel', 'WARNING']: running with PID 20320>

Oct 08 14:11:23 (pikerd[a49d7c], 53180, tractor._spawn.new_proc[629920])) [WARNING] tractor _spawn.py:400 Subactor still alive after cancel request?

uid: Aid(
  name: str = 'samplerd',
  uuid: str = '86ab0690-2d91-4be7-995a-83421a4cea81',
  pid: int|None = 10040,
)
|_<trio.Process ['C:\\Users\\austi\\Documents\\Code\\piker\\piker\\.venv\\Scripts\\python.exe', '-m', 'tractor._child', '--uid', "('samplerd', '86ab0690-2d91-4be7-995a-83421a4cea81')", '--parent_addr', "('127.0.0.1', 6116)", '--loglevel', 'WARNING']: running with PID 52332>

Oct 08 14:11:24 (pikerd[a49d7c], 53180, tractor._spawn.new_proc[625344])) [CRITICAL] tractor _spawn.py:318 #T-800 deployed to collect zombie B0
>x)
 |_<trio.Process ['C:\\Users\\austi\\Documents\\Code\\piker\\piker\\.venv\\Scripts\\python.exe', '-m', 'tractor._child', '--uid', "('brokerd.binance', '20668161-7b71-4ba8-aa27-005be44032a1')", '--parent_addr', "('127.0.0.1', 6116)", '--loglevel', 'WARNING']: exited with status 1>

Oct 08 14:11:24 (pikerd[a49d7c], 53180, tractor._spawn.new_proc[629920])) [CRITICAL] tractor _spawn.py:318 #T-800 deployed to collect zombie B0
>x)
 |_<trio.Process ['C:\\Users\\austi\\Documents\\Code\\piker\\piker\\.venv\\Scripts\\python.exe', '-m', 'tractor._child', '--uid', "('samplerd', '86ab0690-2d91-4be7-995a-83421a4cea81')", '--parent_addr', "('127.0.0.1', 6116)", '--loglevel', 'WARNING']: exited with status 1>

Oct 08 14:11:24 (pikerd[a49d7c], 53180, tractor._spawn.new_proc[933200])) [CRITICAL] tractor _spawn.py:318 #T-800 deployed to collect zombie B0
>x)
 |_<trio.Process ['C:\\Users\\austi\\Documents\\Code\\piker\\piker\\.venv\\Scripts\\python.exe', '-m', 'tractor._child', '--uid', "('emsd', '193ebeda-8743-4f72-9592-e0076892315a')", '--parent_addr', "('127.0.0.1', 6116)", '--loglevel', 'warning']: exited with status 1>

Oct 08 14:11:24 (paperboi.binance[5d9100], 45124, tractor._rpc.process_messages[426336])) [WARNING] tractor _exceptions.py:995 peer IPC channel closed abruptly?

<=x[
  <Channel(
 |_status: 'connected'
 |_peer: 'emsd@38968'
 |_msgstream: MsgpackTCPStream
   maddr: '/ipv4/127.0.0.1/tcp/62893'
   proto: 'tcp'
   layer: 4
   codec: 'msgpack'
   .laddr=TCPAddress[('127.0.0.1', 62902)]
   .raddr=TCPAddress[('127.0.0.1', 62893)]
)>

  |_TCPAddress[('127.0.0.1', 62893)]

'MsgpackTCPStream' already closed by peer
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 222, in _iter_packets
    header: bytes = await self.recv_stream.receive_exactly(4)
                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 107, in receive_exactly
    data = await self.receive(num_bytes)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 53, in receive
    data = await self.transport_stream.receive_some(to_receive)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 140, in receive_some
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 43, in _translate_socket_errors_to_stream_errors
    raise trio.BrokenResourceError(f"socket connection broken: {exc}") from exc

    socket connection broken: [WinError 10054] An existing connection was forcibly closed by the remote host

Traceback (most recent call last):
  File "<frozen runpy>", line 198, in _run_module_as_main
  File "<frozen runpy>", line 88, in _run_code
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Scripts\pikerd.exe\__main__.py", line 10, in <module>
Oct 08 14:11:24 (paperboi.binance[5d9100], 45124, tractor._rpc.process_messages[857952])) [WARNING] tractor _exceptions.py:995 peer IPC channel closed abruptly?

<=x[
  <Channel(
 |_status: 'connected'
 |_peer: 'brokerd.binance@8832'
 |_msgstream: MsgpackTCPStream
   maddr: '/ipv4/127.0.0.1/tcp/62802'
   proto: 'tcp'
   layer: 4
   codec: 'msgpack'
   .laddr=TCPAddress[('127.0.0.1', 55341)]
   .raddr=TCPAddress[('127.0.0.1', 62802)]
)>

  |_TCPAddress[('127.0.0.1', 62802)]

'MsgpackTCPStream' already closed by peer
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_transport.py", line 222, in _iter_packets
    header: bytes = await self.recv_stream.receive_exactly(4)
                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 107, in receive_exactly
    data = await self.receive(num_bytes)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tricycle\_streams.py", line 53, in receive
    data = await self.transport_stream.receive_some(to_receive)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 140, in receive_some
    with _translate_socket_errors_to_stream_errors():
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 158, in __exit__
    self.gen.throw(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_socket.py", line 43, in _translate_socket_errors_to_stream_errors
    raise trio.BrokenResourceError(f"socket connection broken: {exc}") from exc

    socket connection broken: [WinError 10054] An existing connection was forcibly closed by the remote host

  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\click\core.py", line 1161, in __call__
    return self.main(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\click\core.py", line 1082, in main
    rv = self.invoke(ctx)
         ^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\click\core.py", line 1443, in invoke
    return ctx.invoke(self.callback, **ctx.params)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\click\core.py", line 788, in invoke
    return __callback(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\piker\cli\__init__.py", line 195, in pikerd
    trio.run(main)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_core\_run.py", line 2423, in run
    raise runner.main_task_outcome.error
  File "C:\Users\austi\Documents\Code\piker\piker\piker\cli\__init__.py", line 182, in main
    service.open_pikerd(
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\piker\service\_actor_runtime.py", line 194, in open_pikerd
    open_piker_runtime(
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\piker\service\_actor_runtime.py", line 108, in open_piker_runtime
    tractor.open_root_actor(
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_root.py", line 481, in open_root_actor
    collapse_eg(),
    ^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_runtime.py", line 1733, in async_main
    raise internal_err
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_runtime.py", line 1548, in async_main
    collapse_eg(),
    ^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\contextlib.py", line 231, in __aexit__
    await self.gen.athrow(value)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\trionics\_beg.py", line 161, in collapse_eg
    raise exc from None
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\trio\_highlevel_serve_listeners.py", line 34, in _run_handler
    await handler(stream)
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\ipc\_server.py", line 456, in handle_stream_from_peer
    ) = await _rpc.process_messages(
        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_rpc.py", line 1056, in process_messages
    await actor._deliver_ctx_payload(
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_runtime.py", line 646, in _deliver_ctx_payload
    return await ctx._deliver_msg(msg)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_context.py", line 1844, in _deliver_msg
    f'{pformat(re)}\n'
       ^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 62, in pformat
    underscore_numbers=underscore_numbers).pformat(object)
                                           ^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 161, in pformat
    self._format(object, sio, 0, 0, {}, 0)
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 178, in _format
    rep = self._repr(object, context, level)
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 458, in _repr
    repr, readable, recursive = self.format(object, context.copy(),
                                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 471, in format
    return self._safe_repr(object, context, maxlevels, level)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\AppData\Local\Programs\Python\Python312\Lib\pprint.py", line 632, in _safe_repr
    rep = repr(object)
          ^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 627, in pformat
    fields: str = self._mk_fields_str(
                  ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 524, in _mk_fields_str
    and not self.is_inception()
            ^^^^^^^^^^^^^^^^^^^
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 591, in is_inception
    self.src_type
  File "C:\Users\austi\Documents\Code\piker\piker\.venv\Lib\site-packages\tractor\_exceptions.py", line 427, in src_type
    raise TypeError(
TypeError: Failed to lookup src error type with `tractor._exceptions.get_err_type()` :  
LocalProtocolError
( ^^^ this exc was collapsed from a group ^^^ )