daniil-berg/asyncio-taskpool
1
0
Fork 0
generated from daniil-berg/boilerplate-py
Code Issues Pull Requests Projects Releases 31 Wiki Activity

simplified method

Browse Source
This commit is contained in:
Daniil Fajnberg 2022-02-13 20:58:36 +01:00
parent b6aed727e9
commit 05d51eface
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/asyncio_taskpool/session.py
View File

@ -142,16 +142,12 @@ class ControlSession:
async def _parse_command(self, msg: str) -> None: async def _parse_command(self, msg: str) -> None:
try: try:
args, argv = self._parser.parse_known_args(msg.split(' ')) args = self._parser.parse_args(msg.split(' '))
except ArgumentError as e: except ArgumentError as e:
self._writer.write(str(e).encode()) self._writer.write(str(e).encode())
return return
except HelpRequested: except HelpRequested:
return return
if argv:
log.debug("%s sent unknown arguments: %s", self._client_class_name, msg)
self._writer.write(b"Invalid command!")
return
await self._execute_command(args) await self._execute_command(args)
async def listen(self) -> None: async def listen(self) -> None: