chore: more cleanup

Author: inishchith

application_sdk/application/__init__.py

@@ -5,8 +5,8 @@
 from application_sdk.clients.base import BaseClient
 from application_sdk.clients.utils import get_workflow_client
 from application_sdk.constants import ENABLE_MCP
-from application_sdk.events.models import EventRegistration
 from application_sdk.handlers.base import BaseHandler
+from application_sdk.interceptors.models import EventRegistration
 from application_sdk.observability.logger_adaptor import get_logger
 from application_sdk.server import ServerInterface
 from application_sdk.server.fastapi import APIServer, HttpWorkflowTrigger

application_sdk/events/__init__.py

@@ -12,7 +12,7 @@
     WorkflowInterceptorClassInput,
 )
 
-from application_sdk.events.models import (
+from application_sdk.interceptors.models import (
     ApplicationEventNames,
     Event,
     EventMetadata,

application_sdk/interceptors/events.py

@@ -5,7 +5,7 @@
 
 from pydantic import BaseModel, Field, RootModel
 
-from application_sdk.events.models import Event, EventFilter
+from application_sdk.interceptors.models import Event, EventFilter
 from application_sdk.workflows import WorkflowInterface
 
 

application_sdk/events/models.py renamed to application_sdk/interceptors/models.py

@@ -15,7 +15,7 @@
     DAPR_BINDING_OPERATION_CREATE,
     EVENT_STORE_NAME,
 )
-from application_sdk.events.models import Event, EventMetadata, WorkflowStates
+from application_sdk.interceptors.models import Event, EventMetadata, WorkflowStates
 from application_sdk.observability.logger_adaptor import get_logger
 from application_sdk.services._utils import is_component_registered
 
@@ -47,7 +47,7 @@ def enrich_event_metadata(cls, event: Event):
             a Temporal workflow or activity context.
 
         Examples:
-            >>> from application_sdk.events.models import Event
+            >>> from application_sdk.interceptors.models import Event
 
             >>> # Create basic event
             >>> event = Event(event_type="data.processed", data={"count": 100})
@@ -109,7 +109,7 @@ async def publish_event(cls, event: Event):
             Exception: If there's an error during event publishing (logged but not re-raised).
 
         Examples:
-            >>> from application_sdk.events.models import Event
+            >>> from application_sdk.interceptors.models import Event
 
             >>> # Publish workflow status event
             >>> status_event = Event(

application_sdk/server/fastapi/models.py

@@ -2,7 +2,7 @@
 
 from hypothesis import strategies as st
 
-from application_sdk.events.models import Event
+from application_sdk.interceptors.models import Event
 
 # Strategy for generating auth credentials
 auth_credentials_strategy = st.fixed_dictionaries(

application_sdk/services/eventstore.py

@@ -15,7 +15,7 @@
 
 from application_sdk.clients.workflow import WorkflowClient
 from application_sdk.constants import MAX_CONCURRENT_ACTIVITIES
-from application_sdk.events.models import (
+from application_sdk.interceptors.models import (
     ApplicationEventNames,
     Event,
     EventTypes,

application_sdk/test_utils/hypothesis/strategies/server/fastapi/__init__.py

@@ -371,7 +371,7 @@ print(f"Applied config: {applied_config}")
 
 ```python
 from application_sdk.services.eventstore import EventStore
-from application_sdk.events.models import Event
+from application_sdk.interceptors.models import Event
 
 # =============== Basic Event Publishing ===============
 

application_sdk/worker.py

@@ -5,7 +5,7 @@
 import pytest
 
 from application_sdk.constants import EVENT_STORE_NAME
-from application_sdk.events.models import (
+from application_sdk.interceptors.models import (
     ApplicationEventNames,
     Event,
     EventMetadata,