mirror of
https://github.com/gogcom/galaxy-integrations-python-api.git
synced 2026-01-19 04:08:24 -05:00
Revert "Add more logs"
This reverts commit 21ab8bf33d3c2714b8c7af2da8036fe8baae20ea.
This commit is contained in:
@@ -129,8 +129,9 @@ class Server():
|
||||
await asyncio.sleep(0) # To not starve task queue
|
||||
|
||||
def close(self):
|
||||
logging.info("Closing JSON-RPC server - not more messages will be read")
|
||||
self._active = False
|
||||
if self._active:
|
||||
logging.info("Closing JSON-RPC server - not more messages will be read")
|
||||
self._active = False
|
||||
|
||||
async def wait_closed(self):
|
||||
await self._task_manager.wait()
|
||||
@@ -281,6 +282,7 @@ class NotificationClient():
|
||||
self._send(notification)
|
||||
|
||||
async def close(self):
|
||||
self._task_manager.cancel()
|
||||
await self._task_manager.wait()
|
||||
|
||||
def _send(self, data):
|
||||
|
||||
@@ -184,6 +184,7 @@ class Plugin:
|
||||
async def run(self):
|
||||
"""Plugin's main coroutine."""
|
||||
await self._server.run()
|
||||
logging.debug("Plugin run loop finished")
|
||||
|
||||
def close(self) -> None:
|
||||
if not self._active:
|
||||
@@ -196,10 +197,12 @@ class Plugin:
|
||||
self._active = False
|
||||
|
||||
async def wait_closed(self) -> None:
|
||||
logging.debug("Waiting for plugin to close")
|
||||
await self._external_task_manager.wait()
|
||||
await self._internal_task_manager.wait()
|
||||
await self._server.wait_closed()
|
||||
await self._notification_client.close()
|
||||
logging.debug("Plugin closed")
|
||||
|
||||
def create_task(self, coro, description):
|
||||
"""Wrapper around asyncio.create_task - takes care of canceling tasks on shutdown"""
|
||||
|
||||
Reference in New Issue
Block a user