From 6d480b8256f9c6cb9257979fea7f8c8fd4e40fc9 Mon Sep 17 00:00:00 2001 From: Kyle Altendorf Date: Tue, 21 Nov 2023 18:14:10 -0500 Subject: [PATCH] introducer just manage (#16757) --- chia/introducer/introducer.py | 18 ++++-------------- 1 file changed, 4 insertions(+), 14 deletions(-) diff --git a/chia/introducer/introducer.py b/chia/introducer/introducer.py index c36b8bb51883..f97ce6b21216 100644 --- a/chia/introducer/introducer.py +++ b/chia/introducer/introducer.py @@ -38,23 +38,13 @@ class Introducer: @contextlib.asynccontextmanager async def manage(self) -> AsyncIterator[None]: - await self._start() + self._vetting_task = asyncio.create_task(self._vetting_loop()) try: yield finally: - self._close() - await self._await_closed() - - async def _start(self): - self._vetting_task = asyncio.create_task(self._vetting_loop()) - - def _close(self): - self._shut_down = True - self._vetting_task.cancel() - - async def _await_closed(self): - pass - # await self._vetting_task + self._shut_down = True + self._vetting_task.cancel() + # await self._vetting_task async def on_connect(self, peer: WSChiaConnection) -> None: pass