GithubFollow/One-KVM
1
0
Fork 0
mirror of https://github.com/mofeng-git/One-KVM.git synced 2026-01-29 09:01:54 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

basic python 3.9 support

Browse Source
This commit is contained in:
Devaev Maxim
2020-12-02 14:37:48 +03:00
parent 9dbf7f1d0b
commit 2b064a3bee
9 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kvmd/aiotools.py
View File

@@ -65,7 +65,7 @@ def create_short_task(coro: Coroutine) -> asyncio.Task:
def get_short_tasks() -> List[asyncio.Task]:
return [
task
for task in asyncio.Task.all_tasks()
for task in asyncio.all_tasks()
if getattr(task, _ATTR_SHORT_TASK, False)
]

2
kvmd/apps/kvmd/api/auth.py
View File

@@ -56,7 +56,7 @@ async def check_request_auth(auth_manager: AuthManager, exposed: HttpExposed, re
token = request.cookies.get(_COOKIE_AUTH_TOKEN, "")
if token:
user = auth_manager.check(valid_auth_token(token))
user = auth_manager.check(valid_auth_token(token)) # type: ignore
if not user:
set_request_auth_info(request, "- (token)")
raise ForbiddenError()

2
kvmd/apps/kvmd/server.py
View File

@@ -226,7 +226,7 @@ class KvmdServer(HttpServer): # pylint: disable=too-many-arguments,too-many-ins
if name not in current_params:
assert exc_cls is not None, name
raise exc_cls()
value = validator(value)
value = validator(value) # type: ignore
if current_params[name] != value:
self.__new_streamer_params[name] = value
await self.__streamer_notifier.notify()

2
kvmd/apps/kvmd/streamer.py
View File

@@ -308,7 +308,7 @@ class Streamer: # pylint: disable=too-many-instance-attributes
mtime=float(response.headers["X-Timestamp"]),
headers=tuple(
(key, value)
for (key, value) in tools.sorted_kvs(response.headers)
for (key, value) in tools.sorted_kvs(dict(response.headers))
if key.lower().startswith("x-ustreamer-") or key.lower() in [
"x-timestamp",
"access-control-allow-origin",

2
kvmd/apps/vnc/server.py
View File

@@ -435,7 +435,7 @@ class VncServer: # pylint: disable=too-many-instance-attributes
server.close()
loop.run_until_complete(server.wait_closed())
finally:
tasks = asyncio.Task.all_tasks()
tasks = asyncio.all_tasks(loop)
for task in tasks:
task.cancel()
loop.run_until_complete(asyncio.gather(*tasks, return_exceptions=True))