Add initial infected asyncio error propagation test
							parent
							
								
									6476df2c69
								
							
						
					
					
						commit
						43d2439335
					
				| 
						 | 
				
			
			@ -0,0 +1,22 @@
 | 
			
		|||
import asyncio
 | 
			
		||||
 | 
			
		||||
import pytest
 | 
			
		||||
import tractor
 | 
			
		||||
 | 
			
		||||
async def sleep_and_err():
 | 
			
		||||
    await asyncio.sleep(0.1)
 | 
			
		||||
    assert 0
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
async def trio_main():
 | 
			
		||||
    await tractor.to_asyncio.run_task(sleep_and_err)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
def test_infected_simple_error(arb_addr):
 | 
			
		||||
 | 
			
		||||
    async def main():
 | 
			
		||||
        async with tractor.open_nursery() as n:
 | 
			
		||||
            await n.run_in_actor('asyncio_actor', trio_main, infected_asyncio=True)
 | 
			
		||||
 | 
			
		||||
    with pytest.raises(tractor.RemoteActorError) as excinfo:
 | 
			
		||||
        tractor.run(main, arbiter_addr=arb_addr)
 | 
			
		||||
		Loading…
	
		Reference in New Issue