Don't unwrap and unwrapped addr, just warn on delete XD
parent
c93fbcc9f7
commit
8b82808fcd
|
@ -219,13 +219,14 @@ async def maybe_open_portal(
|
||||||
uid: tuple[str, str] = await reg_portal.run_from_ns(
|
uid: tuple[str, str] = await reg_portal.run_from_ns(
|
||||||
'self',
|
'self',
|
||||||
'delete_sockaddr',
|
'delete_sockaddr',
|
||||||
sockaddr=addr.unwrap(),
|
sockaddr=addr,
|
||||||
)
|
)
|
||||||
log.error(
|
log.warning(
|
||||||
f'Deleted stale registry entry !\n'
|
f'Deleted stale registry entry !\n'
|
||||||
f'addr: {addr!r}\n'
|
f'addr: {addr!r}\n'
|
||||||
f'uid: {uid!r}\n'
|
f'uid: {uid!r}\n'
|
||||||
)
|
)
|
||||||
|
yield None
|
||||||
|
|
||||||
|
|
||||||
@acm
|
@acm
|
||||||
|
@ -309,7 +310,6 @@ async def find_actor(
|
||||||
yield portals
|
yield portals
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@acm
|
@acm
|
||||||
async def wait_for_actor(
|
async def wait_for_actor(
|
||||||
name: str,
|
name: str,
|
||||||
|
|
Loading…
Reference in New Issue