Tweak log msg
							parent
							
								
									dd0cfe2f5a
								
							
						
					
					
						commit
						6ae4d8699e
					
				| 
						 | 
				
			
			@ -95,7 +95,7 @@ async def run_task(
 | 
			
		|||
        nonlocal err
 | 
			
		||||
        err = task.exception()
 | 
			
		||||
        if err:
 | 
			
		||||
            log.exception("asyncio task errorred:")
 | 
			
		||||
            log.exception(f"asyncio task errorred:\n{err}")
 | 
			
		||||
        cancel_scope.cancel()
 | 
			
		||||
 | 
			
		||||
    task.add_done_callback(cancel_trio)
 | 
			
		||||
| 
						 | 
				
			
			@ -116,6 +116,7 @@ async def run_task(
 | 
			
		|||
 | 
			
		||||
    # simple async func
 | 
			
		||||
    elif inspect.iscoroutine(coro):
 | 
			
		||||
 | 
			
		||||
        with cancel_scope:
 | 
			
		||||
            # return single value
 | 
			
		||||
            return await from_aio.receive()
 | 
			
		||||
| 
						 | 
				
			
			@ -123,6 +124,7 @@ async def run_task(
 | 
			
		|||
            raise err
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
def run_as_asyncio_guest(
 | 
			
		||||
    trio_main: Callable,
 | 
			
		||||
) -> None:
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in New Issue