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