Revert removal of `infect_asyncio` in nursery start methods
							parent
							
								
									aed60dd7e2
								
							
						
					
					
						commit
						c34d4b54fd
					
				| 
						 | 
				
			
			@ -61,6 +61,7 @@ class ActorNursery:
 | 
			
		|||
        enable_modules: List[str] = None,
 | 
			
		||||
        loglevel: str = None,  # set log level per subactor
 | 
			
		||||
        nursery: trio.Nursery = None,
 | 
			
		||||
        infect_asyncio: bool = False,
 | 
			
		||||
    ) -> Portal:
 | 
			
		||||
        loglevel = loglevel or self._actor.loglevel or get_loglevel()
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -104,6 +105,7 @@ class ActorNursery:
 | 
			
		|||
                bind_addr,
 | 
			
		||||
                parent_addr,
 | 
			
		||||
                _rtv,  # run time vars
 | 
			
		||||
                infect_asyncio=infect_asyncio,
 | 
			
		||||
            )
 | 
			
		||||
        )
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -116,6 +118,7 @@ class ActorNursery:
 | 
			
		|||
        rpc_module_paths: Optional[List[str]] = None,
 | 
			
		||||
        enable_modules: List[str] = None,
 | 
			
		||||
        loglevel: str = None,  # set log level per subactor
 | 
			
		||||
        infect_asyncio: bool = False,
 | 
			
		||||
        **kwargs,  # explicit args to ``fn``
 | 
			
		||||
    ) -> Portal:
 | 
			
		||||
        """Spawn a new actor, run a lone task, then terminate the actor and
 | 
			
		||||
| 
						 | 
				
			
			@ -140,6 +143,7 @@ class ActorNursery:
 | 
			
		|||
            loglevel=loglevel,
 | 
			
		||||
            # use the run_in_actor nursery
 | 
			
		||||
            nursery=self._ria_nursery,
 | 
			
		||||
            infect_asyncio=infect_asyncio,
 | 
			
		||||
        )
 | 
			
		||||
 | 
			
		||||
        # XXX: don't allow stream funcs
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in New Issue