Flip rpc tests over to use `ExceptionGroup` on new `trio`
							parent
							
								
									4fb34772e7
								
							
						
					
					
						commit
						1879243257
					
				|  | @ -329,7 +329,7 @@ async def inf_streamer( | |||
| 
 | ||||
|             # close out the stream gracefully | ||||
|             except trio.ClosedResourceError: | ||||
|                 print('msgstream closed on streamer side!') | ||||
|                 print('transport closed on streamer side!') | ||||
|                 assert stream.closed | ||||
|                 break | ||||
|         else: | ||||
|  |  | |||
|  | @ -10,7 +10,6 @@ from contextlib import asynccontextmanager as acm | |||
| 
 | ||||
| import pytest | ||||
| import trio | ||||
| from trio_typing import TaskStatus | ||||
| import tractor | ||||
| from tractor import RemoteActorError | ||||
| from async_generator import aclosing | ||||
|  |  | |||
|  | @ -112,7 +112,7 @@ def test_rpc_errors(reg_addr, to_call, testdir): | |||
|         value = err.value | ||||
| 
 | ||||
|         # might get multiple `trio.Cancelled`s as well inside an inception | ||||
|         if isinstance(value, trio.MultiError): | ||||
|         if isinstance(value, ExceptionGroup): | ||||
|             value = next(itertools.dropwhile( | ||||
|                 lambda exc: not isinstance(exc, tractor.RemoteActorError), | ||||
|                 value.exceptions | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue