863617d451
Pass func refs
2021-07-05 09:21:37 -04:00
e0ae1608ac
Add initial infected asyncio error propagation test
2021-07-05 09:21:37 -04:00
72a40e82cc
Add fast fail test using the context api
2021-07-05 09:15:16 -04:00
f2a1064b17
Adjust debug tests to accomodate no more root clobbering
...
We may get multiple re-entries to debugger by `bp_forever` sub-actor
now since the root will incrementally try to cancel it only when the tty
lock is not held.
2021-07-05 09:13:12 -04:00
e1533d35dc
Avoid mutate during interate error
2021-07-05 08:46:09 -04:00
8371621e57
Expect context cancelled when we cancel
2021-07-05 08:46:09 -04:00
197d291ba8
Modernize streaming tests
2021-07-05 08:44:25 -04:00
43ce533dbf
Speedup the dynamic pubsub test
2021-07-05 08:44:25 -04:00
f2b1ef3fc9
Add detailed ``@tractor.context`` cancellation/termination tests
2021-07-05 08:44:25 -04:00
b3437dacbe
Add a multi-task streaming test
2021-07-05 08:44:25 -04:00
732b9fe63b
Add error case
2021-07-05 08:44:25 -04:00
ddc6c85d60
Add dynamic pubsub test using new bidir stream apis
2021-07-05 08:44:25 -04:00
3f1adc0b6f
Parametrize with async for style tests
2021-07-05 08:44:25 -04:00
3625a8cd56
Add basic test set
2021-07-05 08:44:25 -04:00
b706cd9d4d
Cancel scope on stream consumer completion
2021-07-05 08:44:25 -04:00
55760b3fe0
Only expect further message in non-name-error first case
2021-07-04 12:55:36 -04:00
9c9309faf8
Handle race for tty by child actors
2021-07-04 10:25:41 -04:00
b372f4c92b
Handle top level multierror that presents now?
2021-07-02 11:55:16 -04:00
2b4cf59ee1
Drop sleep
2021-05-07 11:21:40 -04:00
5ca963148e
Disable leftover debug mode
2021-05-07 11:21:40 -04:00
4798d3b5db
Drop lingering rpc_module_paths refs
2021-05-07 11:21:40 -04:00
247483ee93
Drop run and rpc_module_paths from streaming tests
2021-05-07 11:21:40 -04:00
9e64161538
Drop run and rpc_module_paths from rpc tests
2021-05-07 11:21:40 -04:00
3bddf9a94b
Drop run and rpc_module_paths from spawning tests
2021-05-07 11:21:40 -04:00
1eedd463cb
Drop run and rpc_module_paths from pubsub tests
2021-05-07 11:21:40 -04:00
b46e60ab9d
Drop run from multi prog tests
2021-05-07 11:21:40 -04:00
cb527c2562
Mostly drop run from local tests
2021-05-07 11:21:40 -04:00
1584c547cd
Drop run and rpc_module_paths from discovery tests
2021-05-07 11:21:40 -04:00
2efd8ed167
Drop run and rpc_module_paths from cancel tests
2021-05-07 11:21:40 -04:00
b1f657e246
De-compact async with tuple on 3.8-
...
Turns out can't use the nicer syntax before python 3.9 (even though it
doesn't seem documented anywhere?).
Relates to #207
2021-04-28 16:35:15 -04:00
2498a4963b
Update all tests to new streaming API
2021-04-28 12:23:14 -04:00
1f1619c730
Convert all test suite sync funcs
2021-04-27 12:08:30 -04:00
47565cfbf3
Use root as default name from `tractor.run()`
2021-02-25 08:51:28 -05:00
cd636b270e
Update debug tests to expect 'root' actor name
2021-02-24 13:38:20 -05:00
8fabd27dbe
Lint fixes
2021-02-24 13:13:51 -05:00
a93321e48e
Don't run stdlib example as part of test set
2021-02-21 15:41:21 -05:00
07653bc02e
Run parallel examples
2021-02-21 14:08:23 -05:00
59421d9f3a
Fix some borked tests
2021-01-08 20:55:11 -05:00
5127effd88
Drop warning level logging assert(s)
2020-12-26 15:45:55 -05:00
4bf9b27f57
Drop all .statespace refs; it was a silly idea
2020-12-22 19:33:16 -05:00
0eba5f4708
Port remaining tests to pass func refs
2020-12-22 10:39:47 -05:00
493f2efb50
Port tests to `Portal.run_from_ns()`
2020-12-22 10:39:47 -05:00
a668f714d5
Allow passing function refs to `Portal.run()`
...
This resolves and completes #69 allowing all RPC invocation APIs to pass
function references directly instead of explicit `str` names for the
target namespace and function (this is still done implicitly
underneath). This brings us closer to `trio`'s task running API as well
as acknowledges that any inter-host RPC system (and API) will likely
need to be implemented on top of local RPC primitives anyway. Even if
this ends up **not** being true we can always go to "function stubs" as
part of our IAC protocol or, add a new method to do explicit namespace
calls: `.run_from_module()` or whatever everyone votes on.
Resolves #69
Further, this commit drops `Actor.statespace` from the entire system
since a user can easily get this same functionality using module
level variables. Fix docs to match all these changes (luckily mostly
already done due to example scripts referencing).
2020-12-21 09:09:55 -05:00
dc475b54ab
More obnoxious CI timeout handling
2020-12-18 19:26:29 -05:00
a95488ad2f
Handle pexpect's internal timeout
2020-12-18 17:57:44 -05:00
47f68a0532
Skip debugger tests on non-trio backends
2020-12-17 16:37:05 -05:00
797bcc1df2
Handle early timeouts on last debugger test
2020-12-17 13:35:45 -05:00
201771a521
'Fix mypy, change interal type name to `ReceiveStream`, settle on `.shield()`'
2020-12-17 12:01:49 -05:00
15ead6b561
Add a way to shield a stream's underlying channel
...
Add a ``tractor._portal.StreamReceiveChannel.shield_channel()`` context
manager which allows for avoiding the closing of an IPC stream's
underlying channel for the purposes of task re-spawning. Sometimes you
might want to cancel a task consuming a stream but not tear down the IPC
between actors (the default). A common use can might be where the task's
"setup" work might need to be redone but you want to keep the
established portal / channel in tact despite the task restart.
Includes a test.
2020-12-16 21:42:28 -05:00
0118589875
Add race case handling for mp backend
2020-12-12 13:30:14 -05:00
Tyler Goodlet