forked from goodboy/tractor
				
			Revert removal of `infect_asyncio` in nursery start methods
							parent
							
								
									e54ddac5b9
								
							
						
					
					
						commit
						a6b6241176
					
				|  | @ -62,6 +62,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() | ||||
| 
 | ||||
|  | @ -105,6 +106,7 @@ class ActorNursery: | |||
|                 bind_addr, | ||||
|                 parent_addr, | ||||
|                 _rtv,  # run time vars | ||||
|                 infect_asyncio=infect_asyncio, | ||||
|             ) | ||||
|         ) | ||||
| 
 | ||||
|  | @ -117,6 +119,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 | ||||
|  | @ -141,6 +144,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