Skip to content

Commit 26904b7

Browse files
committed
linter: Multiple fixes across the project to satisfy linters
Signed-off-by: Denys Fedoryshchenko <denys.f@collabora.com>
1 parent 621d9a8 commit 26904b7

14 files changed

Lines changed: 56 additions & 36 deletions

.pylintrc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ py-version=3.10
5656

5757
# When enabled, pylint would attempt to guess common misconfiguration and emit
5858
# user-friendly hints instead of false-positive error messages.
59-
suggestion-mode=yes
59+
# suggestion-mode is removed in pylint 4.x
6060

6161
# Allow loading of arbitrary C extensions. Extensions are imported into the
6262
# active Python interpreter and may run arbitrary code.
@@ -564,5 +564,5 @@ min-public-methods=2
564564

565565
# Exceptions that will emit a warning when being caught. Defaults to
566566
# "BaseException, Exception".
567-
overgeneral-exceptions=BaseException,
568-
Exception
567+
overgeneral-exceptions=builtins.BaseException,
568+
builtins.Exception

api/db.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -73,31 +73,31 @@ async def get_kv(self, namespace, key):
7373
Get value from redis key-value store
7474
Create a keyname by concatenating namespace and key
7575
"""
76-
keyname = f"{namespace}:{key}"
76+
keyname = ":".join([namespace, key])
7777
return await self._redis.get(keyname)
7878

7979
async def set_kv(self, namespace, key, value):
8080
"""
8181
Set value in redis key-value store
8282
Create a keyname by concatenating namespace and key
8383
"""
84-
keyname = f"{namespace}:{key}"
84+
keyname = ":".join([namespace, key])
8585
return await self._redis.set(keyname, value)
8686

8787
async def del_kv(self, namespace, key):
8888
"""
8989
Delete key from redis key-value store
9090
Create a keyname by concatenating namespace and key
9191
"""
92-
keyname = f"{namespace}:{key}"
92+
keyname = ":".join([namespace, key])
9393
return await self._redis.delete(keyname)
9494

9595
async def exists_kv(self, namespace, key):
9696
"""
9797
Check if key exists in redis key-value store
9898
Create a keyname by concatenating namespace and key
9999
"""
100-
keyname = f"{namespace}:{key}"
100+
keyname = ":".join([namespace, key])
101101
return await self._redis.exists(keyname)
102102

103103
async def create_indexes(self):

api/main.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ def _is_proxy_addr() -> bool:
306306

307307
if forwarded_host:
308308
scheme = forwarded_proto or request.url.scheme
309-
return f"{scheme}://{forwarded_host}".rstrip("/")
309+
return (scheme + "://" + forwarded_host).rstrip("/")
310310

311311
return str(request.base_url).rstrip("/")
312312

@@ -746,8 +746,8 @@ def _user_can_edit_node(user: User, node: Node) -> bool:
746746
return True
747747
runtime = _get_node_runtime(node)
748748
if runtime:
749-
runtime_editor = f'runtime:{runtime}:node-editor'
750-
runtime_admin = f'runtime:{runtime}:node-admin'
749+
runtime_editor = ":".join(['runtime', runtime, 'node-editor'])
750+
runtime_admin = ":".join(['runtime', runtime, 'node-admin'])
751751
if (runtime_editor in user_group_names
752752
or runtime_admin in user_group_names):
753753
return True

api/pubsub.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,8 @@ def __init__(self, host=None, db_number=None):
4343
if db_number is None:
4444
db_number = self._settings.redis_db_number
4545
self._redis = aioredis.from_url(
46-
f'redis://{host}/{db_number}', health_check_interval=30
46+
'redis://' + host + '/' + str(db_number),
47+
health_check_interval=30
4748
)
4849
# self._subscriptions is a dict that matches a subscription id
4950
# (key) with a Subscription object ('sub') and a redis

api/pubsub_mongo.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,8 @@ def __init__(self, mongo_client=None, host=None, db_number=None,
7777
db_number = self._settings.redis_db_number
7878

7979
self._redis = aioredis.from_url(
80-
f'redis://{host}/{db_number}', health_check_interval=30
80+
'redis://' + host + '/' + str(db_number),
81+
health_check_interval=30
8182
)
8283

8384
# MongoDB setup

scripts/usermanager.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -294,8 +294,10 @@ def main():
294294
("update-user", "Patch user by id/email/username"),
295295
("whoami", "Show current user"),
296296
]
297-
command_list = "\n".join(f" {name:<18} {desc}" for name, desc in command_help)
298-
default_paths = "\n".join(f" - {path}" for path in DEFAULT_CONFIG_PATHS)
297+
command_list = "\n".join(
298+
" {:<18} {}".format(name, desc) for name, desc in command_help)
299+
default_paths = "\n".join(
300+
" - {}".format(path) for path in DEFAULT_CONFIG_PATHS)
299301
parser = argparse.ArgumentParser(
300302
description="KernelCI API user management helper",
301303
epilog=(

tests/e2e_tests/conftest.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,10 @@
1010
from httpx import AsyncClient
1111
from motor.motor_asyncio import AsyncIOMotorClient
1212

13-
from api.main import versioned_app
1413
from kernelci.api.models import Node, Regression
1514

15+
from api.main import versioned_app
16+
1617
BASE_URL = 'http://api:8000/latest/'
1718
DB_URL = 'mongodb://db:27017'
1819
DB_NAME = 'kernelci'

tests/e2e_tests/test_pipeline.py

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,9 @@ async def test_node_pipeline(test_async_client):
3737
"""
3838

3939
# Create Task to listen pubsub event on 'node' channel
40-
task_listen = create_listen_task(test_async_client,
41-
pytest.node_channel_subscription_id) # pylint: disable=no-member
40+
task_listen = create_listen_task(
41+
test_async_client,
42+
pytest.node_channel_subscription_id) # pylint: disable=no-member
4243

4344
# Create a node
4445
node = {
@@ -48,8 +49,10 @@ async def test_node_pipeline(test_async_client):
4849
"data": {
4950
"kernel_revision": {
5051
"tree": "mainline",
51-
"url": ("https://git.kernel.org/pub/scm/linux/kernel/git/"
52-
"torvalds/linux.git"),
52+
"url": (
53+
"https://git.kernel.org/pub/scm/"
54+
"linux/kernel/git/torvalds/linux.git"
55+
),
5356
"branch": "master",
5457
"commit": "2a987e65025e2b79c6d453b78cb5985ac6e5eb28",
5558
"describe": "v5.16-rc4-31-g2a987e65025e"
@@ -73,8 +76,9 @@ async def test_node_pipeline(test_async_client):
7376
node = response.json()
7477

7578
# Create Task to listen 'updated' event on 'node' channel
76-
task_listen = create_listen_task(test_async_client,
77-
pytest.node_channel_subscription_id) # pylint: disable=no-member
79+
task_listen = create_listen_task(
80+
test_async_client,
81+
pytest.node_channel_subscription_id) # pylint: disable=no-member
7882

7983
# Update node.state
8084
node.update({"state": "done"})

tests/e2e_tests/test_pubsub_handler.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,9 @@ async def test_pubsub_handler(test_async_client):
2323
Use pubsub listener task to verify published event message.
2424
"""
2525
# Create Task to listen pubsub event on 'test_channel' channel
26-
task_listen = create_listen_task(test_async_client,
27-
pytest.test_channel_subscription_id) # pylint: disable=no-member
26+
task_listen = create_listen_task(
27+
test_async_client,
28+
pytest.test_channel_subscription_id) # pylint: disable=no-member
2829

2930
# Created and publish CloudEvent
3031
attributes = {

tests/unit_tests/conftest.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@
3838
t3bAE-pHSzZaSHp7FMlImqgYvL6f_0xDUD-nQwxEm3k'
3939

4040
API_VERSION = 'latest'
41-
BASE_URL = f'http://testserver/{API_VERSION}/'
41+
BASE_URL = 'http://testserver/' + API_VERSION + '/'
4242

4343

4444
def mock_get_current_user(request: Request):
@@ -90,6 +90,7 @@ def mock_get_current_admin_user(request: Request):
9090
is_verified=True
9191
)
9292

93+
9394
# Mock dependency callables for getting current user
9495
app.dependency_overrides[get_current_user] = mock_get_current_user
9596
app.dependency_overrides[get_current_superuser] = mock_get_current_admin_user

0 commit comments

Comments
 (0)