lecris/matrix-puppeteer-line
1
0
Fork 0
forked from fair/matrix-puppeteer-line
Code Issues Pull Requests Projects Releases Wiki Activity

Proper usage of asyncio exceptions

Browse Source 
They belong to the asyncio package, not asyncio.exceptions.
Also remove an unused Tuple import
This commit is contained in:
Andrew Ferrazzutti 2021-07-03 12:49:21 -04:00
parent 0672d41431
commit c4be4d79ed
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
matrix_puppeteer_line/rpc/rpc.py
View File

@ -13,7 +13,7 @@
# #
# You should have received a copy of the GNU Affero General Public License # You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <https://www.gnu.org/licenses/>. # along with this program. If not, see <https://www.gnu.org/licenses/>.
from typing import Dict, Any, Callable, Awaitable, List, Optional, Tuple from typing import Dict, Any, Callable, Awaitable, List, Optional
import logging import logging
import asyncio import asyncio
import json import json
@ -158,10 +158,10 @@ class RPCClient:
try: try:
line += await self._reader.readuntil() line += await self._reader.readuntil()
break break
except asyncio.exceptions.IncompleteReadError as e: except asyncio.IncompleteReadError as e:
line += e.partial line += e.partial
break break
except asyncio.exceptions.LimitOverrunError as e: except asyncio.LimitOverrunError as e:
self.log.warning(f"Buffer overrun: {e}") self.log.warning(f"Buffer overrun: {e}")
line += await self._reader.read(self._reader._limit) line += await self._reader.read(self._reader._limit)
if not line: if not line: