diff --git a/pytec/pytec/aioclient.py b/pytec/pytec/aioclient.py index d88ebfe..39d15e0 100644 --- a/pytec/pytec/aioclient.py +++ b/pytec/pytec/aioclient.py @@ -93,8 +93,7 @@ class Client: async def _command(self, *command): async with self._command_lock: - # protect the read-write process from being cancelled midway - line = await asyncio.shield(self._read_write(command)) + line = await self._read_write(command) response = json.loads(line) logging.debug("%s: %s", command, response)