@@ -160,8 +160,8 @@ async def open_service_mngr(
160160 ):
161161 # impl specific obvi..
162162 init_kwargs .update ({
163- 'actor_n ' : an ,
164- 'service_n ' : tn ,
163+ 'an ' : an ,
164+ 'tn ' : tn ,
165165 })
166166
167167 mngr : ServiceMngr | None
@@ -174,15 +174,11 @@ async def open_service_mngr(
174174 # eventual `@singleton_acm` API wrapper.
175175 #
176176 # assign globally for future daemon/task creation
177- mngr .actor_n = an
178- mngr .service_n = tn
177+ mngr .an = an
178+ mngr .tn = tn
179179
180180 else :
181- assert (
182- mngr .actor_n
183- and
184- mngr .service_tn
185- )
181+ assert (mngr .an and mngr .tn )
186182 log .info (
187183 'Using extant service mngr!\n \n '
188184 f'{ mngr !r} \n ' # it has a nice `.__repr__()` of services state
@@ -349,8 +345,8 @@ class ServiceMngr:
349345 process tree.
350346
351347 '''
352- actor_n : ActorNursery
353- service_n : trio .Nursery
348+ an : ActorNursery
349+ tn : trio .Nursery
354350 debug_mode : bool = False # tractor sub-actor debug mode flag
355351
356352 service_tasks : dict [
@@ -423,7 +419,7 @@ async def _task_manager_start(
423419 (
424420 cs ,
425421 complete ,
426- ) = await self .service_n .start (_task_manager_start )
422+ ) = await self .tn .start (_task_manager_start )
427423
428424 # store the cancel scope and portal for later cancellation or
429425 # retstart if needed.
@@ -485,7 +481,7 @@ async def start_service_ctx(
485481 for details.
486482
487483 '''
488- cs , ipc_ctx , complete , started = await self .service_n .start (
484+ cs , ipc_ctx , complete , started = await self .tn .start (
489485 functools .partial (
490486 _open_and_supervise_service_ctx ,
491487 serman = self ,
@@ -542,7 +538,7 @@ async def start_service(
542538 return sub_ctx
543539
544540 if daemon_name not in self .service_ctxs :
545- portal : Portal = await self .actor_n .start_actor (
541+ portal : Portal = await self .an .start_actor (
546542 daemon_name ,
547543 debug_mode = ( # maybe set globally during allocate
548544 debug_mode
0 commit comments