Code

Bi streaming no debugger stuff#219

Code

Merged

goodboy merged 50 commits intomastergoodboy/tractor:masterfrom bi_streaming_no_debugger_stuffgoodboy/tractor:bi_streaming_no_debugger_stuffCopy head branch name to clipboardJul 31, 2021

+1,961-331

Commits

Commits on Jul 6, 2021

• Add initial bi-directional streaming

  Show description for e3955bb
  goodboy

  committed
  e3955bb

• Expose @context decorator at top level

  goodboy

  committed
  1411454

• Cancel scope on stream consumer completion

  goodboy

  committed
  4846c6d

• Add basic test set

  goodboy

  committed
  4240efc

• Support passing shield at stream contruction

  goodboy

  committed
  1f8966b

• Parametrize with async for style tests

  goodboy

  committed
  98133a9

• Fix typing

  goodboy

  committed
  08eb6bd

• Be more pedantic with error handling

  goodboy

  committed
  e311430

• Add dynamic pubsub test using new bidir stream apis

  goodboy

  committed
  e5bc07f

• Expose msg stream types at top level

  goodboy

  committed
  6559fb7

• Only send stop msg if not received from far end

  goodboy

  committed
  a2e2f7e

• Support no arg to Context.started() like trio

  goodboy

  committed
  9a4244b

• Add error case

  goodboy

  committed
  5b8b7d3

• Only close recv chan if we get a ref

  goodboy

  committed
  39b9896

• Add a multi-task streaming test

  goodboy

  committed
  3999849

• Add a specially handled ContextCancelled error

  goodboy

  committed
  eb3662f

• Expose streaming components at top level

  goodboy

  committed
  409f7f0

• Specially raise a ContextCancelled for a task-context rpc

  goodboy

  committed
  73302d9

• Explicitly formalize context/streaming teardown

  Show description for 348148f
  goodboy

  committed
  348148f

• Fix exception typing

  goodboy

  committed
  1a69727

• Adjustments for non-frozen context dataclass change

  goodboy

  committed
  54916be

• Drop trailing comma

  goodboy

  committed
  196dea8

• Add detailed @tractor.context cancellation/termination tests

  goodboy

  committed
  7c5fd8c

• Speedup the dynamic pubsub test

  goodboy

  committed
  349d82d

• Modernize streaming tests

  goodboy

  committed
  8eb889a

• Don't clobber msg loop mem chan on rx stream close

  Show description for 3d63340
  goodboy

  committed
  3d63340

• Set stream "end of channel" after shielded check!

  Show description for 1703171
  goodboy

  committed
  1703171

• Consider relaying context error via raised-in-scope-nursery task

  goodboy

  committed
  af701c1

• Add temp warning msg for context cancel call

  goodboy

  committed
  3423ea4

• First try: pack cancelled tracebacks and ship to caller

  goodboy

  committed
  c2484e8

• Always shield cancel the caller on cancel-causing-errors, add teardown logging

  goodboy

  committed
  91640fa

• De-densify some code

  goodboy

  committed
  c6cdaf9

• Add pre-stream open error conditions

  goodboy

  committed
  b21e2a6

• Expect context cancelled when we cancel

  goodboy

  committed
  0623de0

• Avoid mutate during interate error

  goodboy

  committed
  a134bc4

• Always hard kill sub-procs on teardown

  Show description for ef725c5
  goodboy

  committed
  ef725c5

• Don't shield on root cancel it can causes hangs

  goodboy

  committed
  b1cd7fd

• Move join event trigger to direct exit path

  goodboy

  committed
  98bbf8e

• Don't enter debug on closed resource errors

  goodboy

  committed
  12f9875

• Drop trip kwarg

  goodboy

  committed
  7f86d63

• Avoid mutate on iterate race

  goodboy

  committed
  9ddb654

• Go back to only logging crashes if no pdb gets engaged

  goodboy

  committed
  2513c65

• Skip debugger tests on windows at module level

  goodboy

  committed
  929b6dc

Commits on Jul 7, 2021

• Flip "trace" level to "transport" level logging

  goodboy

  committed
  31590e8

• Change trace to transport level

  goodboy

  committed
  8c927d7

Commits on Jul 8, 2021

• Mypy fixes

  goodboy

  committed
  fde52d2

• Define explicit adapter level methods for mypy

  goodboy

  committed
  25779d4

• Use "pdb" level logging in debug mode

  goodboy

  committed
  443ebea

• Install test deps and py3.9 for type check job

  goodboy

  committed
  69bbf6a

Commits on Jul 31, 2021

• Add 2-way streaming example to readme and scripts

  goodboy

  committed
  240f591