import fix

Author: HardMax71

backend/app/dlq/manager.py

@@ -23,7 +23,7 @@
 )
 from app.domain.enums.kafka import GroupId, KafkaTopic
 from app.events.schema.schema_registry import SchemaRegistryManager
-from app.infrastructure.kafka.events import (
+from app.domain.events.typed import (
     DLQMessageDiscardedEvent,
     DLQMessageReceivedEvent,
     DLQMessageRetriedEvent,

backend/app/services/coordinator/queue_manager.py

@@ -8,7 +8,7 @@
 from typing import Any, Dict, List, Tuple
 
 from app.core.metrics.context import get_coordinator_metrics
-from app.infrastructure.kafka.events import ExecutionRequestedEvent
+from app.domain.events.typed import ExecutionRequestedEvent
 
 
 class QueuePriority(IntEnum):

backend/tests/integration/dlq/test_dlq_manager.py

@@ -10,7 +10,7 @@
 from app.domain.enums.events import EventType
 from app.domain.enums.kafka import KafkaTopic
 from app.events.schema.schema_registry import SchemaRegistryManager
-from app.infrastructure.kafka.events import DLQMessageReceivedEvent
+from app.domain.events.typed import DLQMessageReceivedEvent
 from app.settings import Settings
 
 from tests.helpers import make_execution_requested_event

backend/tests/integration/services/sse/test_redis_bus.py

@@ -9,7 +9,7 @@
 from app.domain.enums.kafka import KafkaTopic
 from app.domain.enums.notification import NotificationSeverity, NotificationStatus
 from app.domain.events.typed import EventMetadata
-from app.infrastructure.kafka.events import BaseEvent
+from app.domain.events.typed import BaseEvent
 from app.schemas_pydantic.sse import RedisNotificationMessage, RedisSSEMessage
 from app.services.sse.redis_bus import SSERedisBus
 

backend/tests/unit/services/saga/test_execution_saga_steps.py

@@ -3,7 +3,7 @@
 from app.domain.events.typed import ExecutionRequestedEvent
 from app.domain.saga import DomainResourceAllocation, DomainResourceAllocationCreate
 from app.events.core import UnifiedProducer
-from app.infrastructure.kafka.events import BaseEvent
+from app.domain.events.typed import BaseEvent
 from app.services.saga.execution_saga import (
     AllocateResourcesStep,
     CreatePodStep,

backend/tests/unit/services/saga/test_saga_orchestrator_unit.py

@@ -14,7 +14,7 @@
 from app.events.core import UnifiedProducer
 from app.events.event_store import EventStore
 from app.events.schema.schema_registry import SchemaRegistryManager
-from app.infrastructure.kafka.events import BaseEvent
+from app.domain.events.typed import BaseEvent
 from app.services.idempotency.idempotency_manager import IdempotencyManager
 from app.services.saga.base_saga import BaseSaga
 from app.services.saga.saga_orchestrator import SagaOrchestrator

backend/tests/unit/services/sse/test_kafka_redis_bridge.py

@@ -9,7 +9,7 @@
 from app.domain.events.typed import EventMetadata
 from app.events.core import EventDispatcher
 from app.events.schema.schema_registry import SchemaRegistryManager
-from app.infrastructure.kafka.events import BaseEvent
+from app.domain.events.typed import BaseEvent
 from app.services.sse.kafka_redis_bridge import SSEKafkaRedisBridge
 from app.services.sse.redis_bus import SSERedisBus
 from app.settings import Settings