diff options
author | zhukoff-pavel <[email protected]> | 2022-09-14 16:04:34 +0300 |
---|---|---|
committer | zhukoff-pavel <[email protected]> | 2022-09-14 16:04:34 +0300 |
commit | 8bed9e08c47d2f7765bc3637d17cf6be3bead2ed (patch) | |
tree | b536bb3ad328a814f4debaa1358387987cc03499 | |
parent | 3ccd7883d02ccd67ba50bcb06e0f6d055ce91784 (diff) |
Enable E306 rule check
Enable E306 rule check
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: |