Skip to content

Commit

Permalink
Remove some ignored rules
Browse files Browse the repository at this point in the history
  • Loading branch information
Cito committed Apr 29, 2023
1 parent c60205d commit d547aef
Show file tree
Hide file tree
Showing 4 changed files with 47 additions and 44 deletions.
2 changes: 1 addition & 1 deletion docs/make.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
#!/usr/bin/python3.9
#!/usr/bin/python3.10

"""Build HTML from reST files."""

Expand Down
9 changes: 6 additions & 3 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,9 @@ max-branches = 41
max-statements = 95

[tool.ruff.per-file-ignores]
# You can use `ruff rule ...` to see what these ignored rules check
"docs/make.py" = ["INP001"]
"tests/*" = ["N8", "PGH004", "PLR0915", "PT009", "S101"]
"docs/*" = [
"INP001" # allow stand-alone scripts
]
"tests/*" = [
"S101" # allow assert statements
]
4 changes: 2 additions & 2 deletions tests/test_pooled_db.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ def test_threadsafety(dbapi, threadsafety): # noqa: F811


@pytest.mark.parametrize("threadsafety", [1, 2])
def test_create_connection(dbapi, threadsafety): # noqa: F811
def test_create_connection(dbapi, threadsafety): # noqa: F811, PLR0915
dbapi.threadsafety = threadsafety
shareable = threadsafety > 1
pool = PooledDB(
Expand Down Expand Up @@ -675,7 +675,7 @@ def test_rollback(dbapi, threadsafety): # noqa: F811


@pytest.mark.parametrize("threadsafety", [1, 2])
def test_maxconnections(dbapi, threadsafety): # noqa: F811
def test_maxconnections(dbapi, threadsafety): # noqa: F811, PLR0915
dbapi.threadsafety = threadsafety
shareable = threadsafety > 1
pool = PooledDB(dbapi, 1, 2, 2, 3)
Expand Down
76 changes: 38 additions & 38 deletions tests/test_steady_db.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
import pytest

from dbutils.steady_db import SteadyDBConnection, SteadyDBCursor
from dbutils.steady_db import connect as SteadyDBconnect
from dbutils.steady_db import connect as steady_db_connect

from . import mock_db as dbapi

Expand Down Expand Up @@ -107,13 +107,13 @@ def test_broken_connection():
SteadyDBConnection(None)
with pytest.raises(TypeError):
SteadyDBCursor(None)
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
for i in range(3):
db.close()
del db
with pytest.raises(dbapi.OperationalError):
SteadyDBconnect(dbapi, database='error')
db = SteadyDBconnect(dbapi, database='ok')
steady_db_connect(dbapi, database='error')
db = steady_db_connect(dbapi, database='ok')
cursor = db.cursor()
for i in range(3):
cursor.close()
Expand All @@ -126,7 +126,7 @@ def test_broken_connection():

@pytest.mark.parametrize("closeable", [False, True])
def test_close(closeable):
db = SteadyDBconnect(dbapi, closeable=closeable)
db = steady_db_connect(dbapi, closeable=closeable)
assert db._con.valid
db.close()
assert closeable ^ db._con.valid
Expand All @@ -138,8 +138,8 @@ def test_close(closeable):
assert not db._con.valid


def test_connection():
db = SteadyDBconnect(
def test_connection(): # noqa: PLR0915
db = steady_db_connect(
dbapi, 0, None, None, None, True,
'SteadyDBTestDB', user='SteadyDBTestUser')
assert isinstance(db, SteadyDBConnection)
Expand Down Expand Up @@ -259,7 +259,7 @@ def test_connection():


def test_connection_context_handler():
db = SteadyDBconnect(
db = steady_db_connect(
dbapi, 0, None, None, None, True,
'SteadyDBTestDB', user='SteadyDBTestUser')
assert db._con.session == []
Expand All @@ -278,7 +278,7 @@ def test_connection_context_handler():


def test_cursor_context_handler():
db = SteadyDBconnect(
db = steady_db_connect(
dbapi, 0, None, None, None, True,
'SteadyDBTestDB', user='SteadyDBTestUser')
assert db._con.open_cursors == 0
Expand All @@ -290,7 +290,7 @@ def test_cursor_context_handler():


def test_cursor_as_iterator_provided():
db = SteadyDBconnect(
db = steady_db_connect(
dbapi, 0, None, None, None, True,
'SteadyDBTestDB', user='SteadyDBTestUser')
assert db._con.open_cursors == 0
Expand All @@ -309,7 +309,7 @@ def test_cursor_as_iterator_provided():


def test_cursor_as_iterator_created():
db = SteadyDBconnect(
db = steady_db_connect(
dbapi, 0, None, None, None, True,
'SteadyDBTestDB', user='SteadyDBTestUser')
assert db._con.open_cursors == 0
Expand All @@ -322,10 +322,10 @@ def test_cursor_as_iterator_created():


def test_connection_creator_function():
db1 = SteadyDBconnect(
db1 = steady_db_connect(
dbapi, 0, None, None, None, True,
'SteadyDBTestDB', user='SteadyDBTestUser')
db2 = SteadyDBconnect(
db2 = steady_db_connect(
dbapi.connect, 0, None, None, None, True,
'SteadyDBTestDB', user='SteadyDBTestUser')
assert db1.dbapi() == db2.dbapi()
Expand All @@ -338,7 +338,7 @@ def test_connection_creator_function():


def test_connection_maxusage():
db = SteadyDBconnect(dbapi, 10)
db = steady_db_connect(dbapi, 10)
cursor = db.cursor()
for i in range(100):
cursor.execute(f'select test{i}')
Expand Down Expand Up @@ -389,7 +389,7 @@ def test_connection_maxusage():


def test_connection_setsession():
db = SteadyDBconnect(dbapi, 3, ('set time zone', 'set datestyle'))
db = steady_db_connect(dbapi, 3, ('set time zone', 'set datestyle'))
assert hasattr(db, '_usage')
assert db._usage == 0
assert hasattr(db._con, 'open_cursors')
Expand Down Expand Up @@ -448,29 +448,29 @@ def test_connection_setsession():


def test_connection_failures():
db = SteadyDBconnect(dbapi)
db = steady_db_connect(dbapi)
db.close()
db.cursor()
db = SteadyDBconnect(dbapi, failures=dbapi.InternalError)
db = steady_db_connect(dbapi, failures=dbapi.InternalError)
db.close()
db.cursor()
db = SteadyDBconnect(dbapi, failures=dbapi.OperationalError)
db = steady_db_connect(dbapi, failures=dbapi.OperationalError)
db.close()
with pytest.raises(dbapi.InternalError):
db.cursor()
db = SteadyDBconnect(dbapi, failures=(
db = steady_db_connect(dbapi, failures=(
dbapi.OperationalError, dbapi.InterfaceError))
db.close()
with pytest.raises(dbapi.InternalError):
db.cursor()
db = SteadyDBconnect(dbapi, failures=(
db = steady_db_connect(dbapi, failures=(
dbapi.OperationalError, dbapi.InterfaceError, dbapi.InternalError))
db.close()
db.cursor()


def test_connection_failure_error():
db = SteadyDBconnect(dbapi)
db = steady_db_connect(dbapi)
cursor = db.cursor()
db.close()
cursor.execute('select test')
Expand All @@ -481,7 +481,7 @@ def test_connection_failure_error():


def test_connection_set_sizes():
db = SteadyDBconnect(dbapi)
db = steady_db_connect(dbapi)
cursor = db.cursor()
cursor.execute('get sizes')
result = cursor.fetchone()
Expand Down Expand Up @@ -510,15 +510,15 @@ def test_connection_ping_check():
con_cls = dbapi.Connection
con_cls.has_ping = False
con_cls.num_pings = 0
db = SteadyDBconnect(dbapi)
db = steady_db_connect(dbapi)
db.cursor().execute('select test')
assert con_cls.num_pings == 0
db.close()
db.cursor().execute('select test')
assert con_cls.num_pings == 0
assert db._ping_check() is None
assert con_cls.num_pings == 1
db = SteadyDBconnect(dbapi, ping=7)
db = steady_db_connect(dbapi, ping=7)
db.cursor().execute('select test')
assert con_cls.num_pings == 2
db.close()
Expand All @@ -527,15 +527,15 @@ def test_connection_ping_check():
assert db._ping_check() is None
assert con_cls.num_pings == 2
con_cls.has_ping = True
db = SteadyDBconnect(dbapi)
db = steady_db_connect(dbapi)
db.cursor().execute('select test')
assert con_cls.num_pings == 2
db.close()
db.cursor().execute('select test')
assert con_cls.num_pings == 2
assert db._ping_check()
assert con_cls.num_pings == 3
db = SteadyDBconnect(dbapi, ping=1)
db = steady_db_connect(dbapi, ping=1)
db.cursor().execute('select test')
assert con_cls.num_pings == 3
db.close()
Expand All @@ -546,13 +546,13 @@ def test_connection_ping_check():
db.close()
assert db._ping_check()
assert con_cls.num_pings == 5
db = SteadyDBconnect(dbapi, ping=7)
db = steady_db_connect(dbapi, ping=7)
db.cursor().execute('select test')
assert con_cls.num_pings == 7
db.close()
db.cursor().execute('select test')
assert con_cls.num_pings == 9
db = SteadyDBconnect(dbapi, ping=3)
db = steady_db_connect(dbapi, ping=3)
assert con_cls.num_pings == 9
db.cursor()
assert con_cls.num_pings == 10
Expand All @@ -561,7 +561,7 @@ def test_connection_ping_check():
assert con_cls.num_pings == 11
cursor.execute('select test')
assert con_cls.num_pings == 11
db = SteadyDBconnect(dbapi, ping=5)
db = steady_db_connect(dbapi, ping=5)
assert con_cls.num_pings == 11
db.cursor()
assert con_cls.num_pings == 11
Expand All @@ -575,7 +575,7 @@ def test_connection_ping_check():
assert con_cls.num_pings == 12
cursor.execute('select test')
assert con_cls.num_pings == 13
db = SteadyDBconnect(dbapi, ping=7)
db = steady_db_connect(dbapi, ping=7)
assert con_cls.num_pings == 13
db.cursor()
assert con_cls.num_pings == 14
Expand All @@ -597,7 +597,7 @@ def test_connection_ping_check():


def test_begin_transaction():
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
cursor = db.cursor()
cursor.close()
cursor.execute('select test12')
Expand All @@ -624,7 +624,7 @@ def test_begin_transaction():


def test_with_begin_extension():
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
db._con._begin_called_with = None

def begin(a, b=None, c=7):
Expand All @@ -639,7 +639,7 @@ def begin(a, b=None, c=7):


def test_cancel_transaction():
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
cursor = db.cursor()
db.begin()
cursor.execute('select test14')
Expand All @@ -650,7 +650,7 @@ def test_cancel_transaction():


def test_with_cancel_extension():
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
db._con._cancel_called = None

def cancel():
Expand All @@ -666,20 +666,20 @@ def cancel():


def test_reset_transaction():
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
db.begin()
assert not db._con.session
db.close()
assert not db._con.session
db = SteadyDBconnect(dbapi, database='ok', closeable=False)
db = steady_db_connect(dbapi, database='ok', closeable=False)
db.begin()
assert not db._con.session
db.close()
assert db._con.session == ['rollback']


def test_commit_error():
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
db.begin()
assert not db._con.session
assert db._con.valid
Expand All @@ -703,7 +703,7 @@ def test_commit_error():


def test_rollback_error():
db = SteadyDBconnect(dbapi, database='ok')
db = steady_db_connect(dbapi, database='ok')
db.begin()
assert not db._con.session
assert db._con.valid
Expand Down

0 comments on commit d547aef

Please sign in to comment.