Fix formatting and skip tests in default CI pipelines

Author: uglide

tests/scenario/__init__.py

@@ -1,9 +1,9 @@
+import dataclasses
 import json
 import os.path
-import dataclasses
+from urllib.parse import urlparse
 
 import pytest
-from urllib.parse import urlparse
 
 
 @dataclasses.dataclass
@@ -38,7 +38,9 @@ def get_endpoint(request: pytest.FixtureRequest, endpoint_name: str) -> Endpoint
     endpoints_config_path = request.config.getoption("--endpoints-config")
 
     if not (endpoints_config_path and os.path.exists(endpoints_config_path)):
-        raise ValueError(f"Endpoints config file not found: {endpoints_config_path}")
+        raise FileNotFoundError(
+            f"Endpoints config file not found: {endpoints_config_path}"
+        )
 
     try:
         with open(endpoints_config_path, "r") as f:

tests/scenario/fake_app.py

@@ -1,8 +1,8 @@
 import multiprocessing
 import typing
-
-from threading import Thread, Event
-from multiprocessing import Process, Event as PEvent
+from multiprocessing import Event as PEvent
+from multiprocessing import Process
+from threading import Event, Thread
 from unittest.mock import patch
 
 from redis import Redis

tests/scenario/test_connection_interruptions.py

@@ -1,23 +1,17 @@
 import multiprocessing
-
-import socket
 import time
 
 import pytest
-
-
-from redis import Redis, BusyLoadingError
+from redis import BusyLoadingError, Redis
 from redis.backoff import ExponentialBackoff
+from redis.exceptions import ConnectionError as RedisConnectionError
+from redis.exceptions import TimeoutError as RedisTimeoutError
 from redis.retry import Retry
-from redis.exceptions import (
-    ConnectionError as RedisConnectionError,
-    TimeoutError as RedisTimeoutError,
-)
 
 from ..conftest import _get_client
-from . import get_endpoint, Endpoint
+from . import Endpoint, get_endpoint
 from .fake_app import FakeApp, FakeSubscriber
-from .fault_injection_client import FaultInjectionClient, TriggeredAction
+from .fault_injection_client import FaultInjectionClient
 
 
 @pytest.fixture
@@ -27,7 +21,12 @@ def endpoint_name():
 
 @pytest.fixture
 def endpoint(request: pytest.FixtureRequest, endpoint_name: str):
-    return get_endpoint(request, endpoint_name)
+    try:
+        return get_endpoint(request, endpoint_name)
+    except FileNotFoundError as e:
+        pytest.skip(
+            f"Skipping scenario test because endpoints file is missing: {str(e)}"
+        )
 
 
 @pytest.fixture

tests/test_asyncio/scenario/fake_app.py

@@ -1,6 +1,5 @@
 import typing
-
-from asyncio import create_task, Event, Task
+from asyncio import Event, Task, create_task
 from unittest.mock import patch
 
 from redis.asyncio import Redis

tests/test_asyncio/scenario/test_connection_interruptions.py

@@ -1,13 +1,13 @@
 import asyncio
-import pytest
 
-from redis.asyncio import Redis, BusyLoadingError
-from redis.backoff import ExponentialBackoff
+import pytest
+from redis.asyncio import BusyLoadingError, Redis
 from redis.asyncio.retry import Retry
-from redis.exceptions import ConnectionError as RedisConnectionError, TimeoutError
+from redis.backoff import ExponentialBackoff
+from redis.exceptions import ConnectionError as RedisConnectionError
+from redis.exceptions import TimeoutError
+from tests.scenario import Endpoint, get_endpoint
 
-from ..conftest import create_redis
-from tests.scenario import get_endpoint, Endpoint
 from .fake_app import AsyncFakeApp, AsyncFakeSubscriber
 from .fault_injection_client import AsyncFaultInjectionClient
 
@@ -19,7 +19,12 @@ async def endpoint_name():
 
 @pytest.fixture
 async def endpoint(request: pytest.FixtureRequest, endpoint_name: str):
-    return get_endpoint(request, endpoint_name)
+    try:
+        return get_endpoint(request, endpoint_name)
+    except FileNotFoundError as e:
+        pytest.skip(
+            f"Skipping scenario test because endpoints file is missing: {str(e)}"
+        )
 
 
 @pytest.fixture