k8s integration -> e2e, also update pytest marks

Author: HardMax71

.github/workflows/backend-ci.yml

@@ -175,8 +175,8 @@ jobs:
           name: backend-logs
           path: logs/
 
-  k8s-integration:
-    name: K8s Integration Tests
+  e2e:
+    name: E2E Tests
     runs-on: ubuntu-latest
 
     steps:
@@ -250,7 +250,7 @@ jobs:
           timeout 90 bash -c 'until sudo k3s kubectl cluster-info; do sleep 5; done'
           kubectl create namespace integr8scode --dry-run=client -o yaml | kubectl apply -f -
 
-      - name: Run k8s integration tests
+      - name: Run E2E tests
         timeout-minutes: 10
         env:
           MONGO_ROOT_USER: root

backend/tests/integration/app/test_main_app.py

@@ -12,7 +12,7 @@
     RequestSizeLimitMiddleware,
 )
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 def test_create_app_real_instance(app) -> None:  # type: ignore[valid-type]

backend/tests/integration/db/repositories/test_admin_events_repository.py

@@ -9,7 +9,7 @@
 from app.domain.events.event_models import EventFields, EventFilter, EventStatistics, Event
 from app.infrastructure.kafka.events.metadata import AvroEventMetadata
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()

backend/tests/integration/db/repositories/test_admin_settings_repository.py

@@ -3,7 +3,7 @@
 from app.db.repositories.admin.admin_settings_repository import AdminSettingsRepository
 from app.domain.admin import SystemSettings
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()

backend/tests/integration/db/repositories/test_admin_user_repository.py

@@ -5,7 +5,7 @@
 from app.domain.user import UserFields, UserUpdate, PasswordReset
 from app.core.security import SecurityService
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()

backend/tests/integration/db/repositories/test_dlq_repository.py

@@ -6,7 +6,7 @@
 from app.domain.enums.events import EventType
 from app.dlq import DLQFields, DLQMessageStatus
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()

backend/tests/integration/db/repositories/test_event_repository.py

@@ -6,7 +6,7 @@
 from app.domain.events.event_models import Event, EventFields, EventFilter
 from app.infrastructure.kafka.events.metadata import AvroEventMetadata
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()

backend/tests/integration/db/repositories/test_notification_repository.py

@@ -12,7 +12,7 @@
 )
 from app.domain.user import UserFields
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()

backend/tests/integration/db/repositories/test_replay_repository.py

@@ -8,7 +8,7 @@
 from app.domain.replay import ReplayConfig, ReplayFilter
 from app.schemas_pydantic.replay_models import ReplaySession
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()

backend/tests/integration/db/repositories/test_saga_repository.py

@@ -6,7 +6,7 @@
 from app.domain.enums.saga import SagaState
 from app.domain.saga.models import Saga, SagaFilter, SagaListResult
 
-pytestmark = pytest.mark.unit
+pytestmark = pytest.mark.integration
 
 
 @pytest.fixture()
@@ -25,7 +25,7 @@ async def test_saga_crud_and_queries(repo: SagaRepository, db) -> None:  # type:
     saga = await repo.get_saga("s1")
     assert saga and saga.saga_id == "s1"
     lst = await repo.get_sagas_by_execution("e1")
-    assert len(lst) >= 1
+    assert len(lst.sagas) >= 1
 
     f = SagaFilter(execution_ids=["e1"])
     result = await repo.list_sagas(f, limit=2)