Code

Infect asyncio#121

Code

Merged

goodboy merged 53 commits intomastergoodboy/tractor:masterfrom infect_asynciogoodboy/tractor:infect_asyncioCopy head branch name to clipboardDec 17, 2021

+1,184-30

Commits

Commits on Dec 17, 2021

• First draft "infected asyncio mode"

  Show description for acd63d0
  goodboy

  committed
  acd63d0

  Copy full SHA for acd63d0

• Wow, fix all the broken async func invoking code..

  Show description for 1825b21
  goodboy

  committed
  1825b21

  Copy full SHA for 1825b21

• Attempt to make mypy happy..

  goodboy

  committed
  055788c

  Copy full SHA for 055788c

• Add infect_asyncio: bool flag to nursery methods

  goodboy

  committed
  1406ddc

  Copy full SHA for 1406ddc

• Support asyncio actors with the trio spawner backend

  goodboy

  committed
  8070b16

  Copy full SHA for 8070b16

• Log any asyncio error

  goodboy

  committed
  2cf8714

  Copy full SHA for 2cf8714

• Raise from asyncio error; fixes mypy

  goodboy

  committed
  80f47de

  Copy full SHA for 80f47de

• Raise any asyncio errors if in trio task on cancel

  goodboy

  committed
  509ae13

  Copy full SHA for 509ae13

• Add initial infected asyncio error propagation test

  goodboy

  committed
  340effa

  Copy full SHA for 340effa

• WIP redo asyncio async gen streaming

  goodboy

  committed
  d80f8d7

  Copy full SHA for d80f8d7

• Pass infect_asyncio flag to mp actors as well

  goodboy

  committed
  793bcfb

  Copy full SHA for 793bcfb

• Proxy asyncio cancelleds as well

  goodboy

  committed
  aa24bbc

  Copy full SHA for aa24bbc

• Drop bad .close() call

  goodboy

  committed
  55e210f

  Copy full SHA for 55e210f

• Fix error propagation on asyncio streaming tasks

  goodboy

  committed
  325c0cd

  Copy full SHA for 325c0cd

• Drop old implementation cruft

  goodboy

  committed
  d9dac3f

  Copy full SHA for d9dac3f

• Always cancel the asyncio task?

  goodboy

  committed
  c262b1a

  Copy full SHA for c262b1a

• First draft: .to_asyncio.open_channel_from()

  goodboy

  committed
  b376b7c

  Copy full SHA for b376b7c

• Facepalm, re-raise captured asyncio task error

  goodboy

  committed
  7a65165

  Copy full SHA for 7a65165

• Drop old (and deluded) "streaming" cruft

  goodboy

  committed
  41eddff

  Copy full SHA for 41eddff

• Plan asyncio test set

  goodboy

  committed
  299e419

  Copy full SHA for 299e419

• Clean type imports

  goodboy

  committed
  446feff

  Copy full SHA for 446feff

• Drop runtime logging for asyncio mode

  goodboy

  committed
  06fa650

  Copy full SHA for 06fa650

• Fill out nursery docstring

  goodboy

  committed
  0ab5e5c

  Copy full SHA for 0ab5e5c

• Add a Portal.cancel_actor() test

  goodboy

  committed
  5635724

  Copy full SHA for 5635724

• Adjust linked-loop-task tear down sequence

  Show description for 1114b69
  goodboy

  committed
  1114b69

  Copy full SHA for 1114b69

• Add an asyncio-internal cancel test

  Show description for 04c0eda
  goodboy

  committed
  04c0eda

  Copy full SHA for 04c0eda

• Reverse the order for asyncio cancelleds? I dunno why

  goodboy

  committed
  8704664

  Copy full SHA for 8704664

• Add trio-cancels-anursery-cancels-aio test

  goodboy

  committed
  c19123b

  Copy full SHA for c19123b

• Add a cancelled-from-remote-trio-task case

  goodboy

  committed
  e815f76

  Copy full SHA for e815f76

• Serious-ify doc string

  goodboy

  committed
  e6687bc

  Copy full SHA for e6687bc

• Factor error translation into a ctx mngr

  Show description for 9bc94b5
  goodboy

  committed
  9bc94b5

  Copy full SHA for 9bc94b5

• Add a basic open_channel_from() streaming test

  goodboy

  committed
  d27ddb7

  Copy full SHA for d27ddb7

• Add a LinkedTaskChannel for synced inter-loop-streaming

  Show description for 44d0e9f
  goodboy

  committed
  44d0e9f

  Copy full SHA for 44d0e9f

• Add first set of interloop streaming tests

  goodboy

  committed
  ad2567d

  Copy full SHA for ad2567d

• Flip doc strings to my preferred format

  goodboy

  committed
  c48c68c

  Copy full SHA for c48c68c

• Re-wrap and raise asyncio.CancelledError

  Show description for 5f40946
  goodboy

  committed
  5f40946

  Copy full SHA for 5f40946

• Collect asyncio task exceptions to avoid warning msg

  goodboy

  committed
  6803891

  Copy full SHA for 6803891

• Port tests to handle our new asyncio cancelled type

  goodboy

  committed
  c4b3bb3

  Copy full SHA for c4b3bb3

• Drop cancel scope from linked task channel

  goodboy

  committed
  b69412a

  Copy full SHA for b69412a

• Add an asyncio echo server test

  goodboy

  committed
  2b9b29e

  Copy full SHA for 2b9b29e

• Add mid stream echoserver "bail" cases

  goodboy

  committed
  9a2de90

  Copy full SHA for 9a2de90

• Return channel type from _run_asyncio_task()

  Show description for 56cc983
  goodboy

  committed
  56cc983

  Copy full SHA for 56cc983

• More doc string style tweaks

  goodboy

  committed
  24078f2

  Copy full SHA for 24078f2

• Increase kbi delay in remote cancel test

  goodboy

  committed
  d65912e

  Copy full SHA for d65912e

• Add infected asyncio echo server example

  goodboy

  committed
  b463841

  Copy full SHA for b463841

• Add asyncio echo server ex to readme; fix cluster section

  goodboy

  committed
  7237d69

  Copy full SHA for 7237d69

• Add features bullet, slip in a guille-ism

  goodboy

  committed
  6952c7d

  Copy full SHA for 6952c7d

• Not enough time for new asyncio tests?

  goodboy

  committed
  1fdcaf3

  Copy full SHA for 1fdcaf3

• Emphasize asyncio only with sleeps

  goodboy

  committed
  73d252e

  Copy full SHA for 73d252e

• Link to SC on wikipedia

  goodboy

  committed
  4c0cfa6

  Copy full SHA for 4c0cfa6

• Link to inter-loop channel issue in readme

  goodboy

  committed
  4d1a48a

  Copy full SHA for 4d1a48a

• Add nooz

  goodboy

  committed
  9b14d82

  Copy full SHA for 9b14d82

• Add agpl header

  goodboy

  committed
  9b4cdb0

  Copy full SHA for 9b4cdb0