fix format

Author: kossman

src/corva/handlers.py

@@ -41,7 +41,11 @@
 StreamEventT = TypeVar("StreamEventT", bound=StreamEvent)
 ScheduledEventT = TypeVar("ScheduledEventT", bound=ScheduledEvent)
 HANDLERS: Dict[Type[RawBaseEvent], Callable] = {}
-GENERIC_APP_EVENT_TYPES = (RawStreamEvent, RawScheduledEvent, RawTaskEvent,)
+GENERIC_APP_EVENT_TYPES = (
+    RawStreamEvent,
+    RawScheduledEvent,
+    RawTaskEvent,
+)
 
 
 def get_cache_key(
@@ -89,8 +93,8 @@ def wrapper(aws_event: Any, aws_context: Any) -> List[Any]:
                 validate_app_type_context(aws_event, raw_event_type)
 
             if (
-                    is_direct_app_call
-                    and data_transformation_type not in GENERIC_APP_EVENT_TYPES
+                is_direct_app_call
+                and data_transformation_type not in GENERIC_APP_EVENT_TYPES
             ):
                 CORVA_LOGGER.warning(
                     f"Handler for {data_transformation_type.__name__!r} "

src/corva/validate_app_init.py

@@ -7,7 +7,6 @@
 import pydantic
 
 from corva.models.base import AppType, RawBaseEvent
-from corva.models.merge.raw import RawPartialRerunMergeEvent
 
 
 def find_leaf_subclasses(base_class):

tests/unit/test_apps_event_types.py

@@ -12,8 +12,15 @@
 )
 from corva.models.scheduled.scheduler_type import SchedulerType
 from corva.models.stream.log_type import LogType
-from corva.models.stream.raw import RawStreamEvent, RawStreamTimeEvent, RawTimeRecord, RawMetadata, RawAppMetadata, \
-    RawStreamDepthEvent, RawDepthRecord
+from corva.models.stream.raw import (
+    RawAppMetadata,
+    RawDepthRecord,
+    RawMetadata,
+    RawStreamDepthEvent,
+    RawStreamEvent,
+    RawStreamTimeEvent,
+    RawTimeRecord,
+)
 from corva.models.task import RawTaskEvent
 from corva.validate_app_init import (
     read_manifest,
@@ -160,9 +167,7 @@ def test__if_manifested_app_type_is_none__payload_based_validation_called(contex
             "corva.validate_app_init.validate_event_payload",
             wraps=validate_event_payload,
         ) as mocked_validate_event_payload:
-            validate_app_type_context(
-                aws_event=task_event, raw_event_type=RawTaskEvent
-            )
+            validate_app_type_context(aws_event=task_event, raw_event_type=RawTaskEvent)
 
     mocked_validate_event_payload.assert_called_once()