summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorzhukoff-pavel <[email protected]>2022-09-14 16:04:34 +0300
committerzhukoff-pavel <[email protected]>2022-09-14 16:04:34 +0300
commit8bed9e08c47d2f7765bc3637d17cf6be3bead2ed (patch)
treeb536bb3ad328a814f4debaa1358387987cc03499
parent3ccd7883d02ccd67ba50bcb06e0f6d055ce91784 (diff)
Enable E306 rule check
Enable E306 rule check
-rw-r--r--ydb/tests/functional/serverless/test.py2
-rw-r--r--ydb/tests/functional/sqs/common/test_queues_managing.py2
-rw-r--r--ydb/tests/functional/sqs/messaging/test_generic_messaging.py3
-rw-r--r--ydb/tests/library/serializability/checker.py1
4 files changed, 8 insertions, 0 deletions
diff --git a/ydb/tests/functional/serverless/test.py b/ydb/tests/functional/serverless/test.py
index 9d7462ce873..eece71a7412 100644
--- a/ydb/tests/functional/serverless/test.py
+++ b/ydb/tests/functional/serverless/test.py
@@ -268,8 +268,10 @@ def test_database_with_disk_quotas(ydb_hostel_db, ydb_disk_quoted_serverless_db,
class SessionHolder(object):
def __init__(self, session):
self.session = session
+
def __enter__(self):
return self.session
+
def __exit__(self, exc_type=None, exc_value=None, exc_traceback=None):
if exc_type is None and exc_value is None:
sessions.append(self.session)
diff --git a/ydb/tests/functional/sqs/common/test_queues_managing.py b/ydb/tests/functional/sqs/common/test_queues_managing.py
index 198d38c2c53..1e207b84de7 100644
--- a/ydb/tests/functional/sqs/common/test_queues_managing.py
+++ b/ydb/tests/functional/sqs/common/test_queues_managing.py
@@ -53,6 +53,7 @@ class QueuesManagingTest(KikimrSqsTestBase):
@pytest.mark.parametrize(**TABLES_FORMAT_PARAMS)
def test_create_fifo_queue_wo_postfix(self, tables_format):
self._init_with_params(tables_format=tables_format)
+
def call_create():
self.called = True
self._sqs_api.create_queue(self.queue_name, is_fifo=True)
@@ -91,6 +92,7 @@ class QueuesManagingTest(KikimrSqsTestBase):
@pytest.mark.parametrize(**TABLES_FORMAT_PARAMS)
def test_create_queue_with_invalid_name(self, tables_format):
self._init_with_params(tables_format=tables_format)
+
def call_create():
self._sqs_api.create_queue('invalid_queue_name!')
diff --git a/ydb/tests/functional/sqs/messaging/test_generic_messaging.py b/ydb/tests/functional/sqs/messaging/test_generic_messaging.py
index a597c8d285a..c2893bd75af 100644
--- a/ydb/tests/functional/sqs/messaging/test_generic_messaging.py
+++ b/ydb/tests/functional/sqs/messaging/test_generic_messaging.py
@@ -28,6 +28,7 @@ class SqsGenericMessagingTest(KikimrSqsTestBase):
return
# break a queue and check failure
self._break_queue(self._username, self.queue_name, is_fifo)
+
def call_send():
group = 'trololo' if is_fifo else None
dedup = group
@@ -1036,6 +1037,7 @@ class SqsGenericMessagingTest(KikimrSqsTestBase):
@pytest.mark.parametrize(**TABLES_FORMAT_PARAMS)
def test_invalid_queue_url(self, tables_format):
self._init_with_params(tables_format=tables_format)
+
def call_with_invalid_queue_url():
self._sqs_api.get_queue_attributes('invalid_queue_url')
@@ -1047,6 +1049,7 @@ class SqsGenericMessagingTest(KikimrSqsTestBase):
@pytest.mark.parametrize(**TABLES_FORMAT_PARAMS)
def test_empty_queue_url(self, tables_format):
self._init_with_params(tables_format=tables_format)
+
def call_with_empty_queue_url():
self._sqs_api.send_message(queue_url='', message_body='body')
diff --git a/ydb/tests/library/serializability/checker.py b/ydb/tests/library/serializability/checker.py
index 79255179c4b..9be9619a2eb 100644
--- a/ydb/tests/library/serializability/checker.py
+++ b/ydb/tests/library/serializability/checker.py
@@ -510,6 +510,7 @@ class SerializabilityChecker(object):
parts = []
first = None
last = None
+
def flush():
if first is not None:
if (last - first) > 1: