fix(entity_type): send channel notification once

src/dispatch/entity_type/flows.py

@@ -1,15 +1,11 @@
-import logging
 from sqlalchemy.orm import Session
-from dispatch.case.messaging import send_entity_update_notification
 from dispatch.entity_type.models import EntityScopeEnum
 from dispatch.signal.models import SignalInstance
 from dispatch.entity_type import service as entity_type_service
 
 from dispatch.entity_type.models import EntityType
 from dispatch.entity import service as entity_service
 
-log = logging.getLogger(__file__)
-
 
 def recalculate_entity_flow(
     db_session: Session,
@@ -38,13 +34,4 @@ def recalculate_entity_flow(
         signal_instance.entities = entities
         db_session.commit()
 
-    try:
-        send_entity_update_notification(
-            db_session=db_session,
-            entity_type=entity_type,
-            case=signal_instance.case,
-        )
-    except Exception as e:
-        log.warning(f"Failed to send entity update notification: {e}")
-
     return signal_instance

src/dispatch/entity_type/views.py

@@ -1,8 +1,10 @@
+import logging
 
 from fastapi import APIRouter, HTTPException, status
 from pydantic import ValidationError
 from sqlalchemy.exc import IntegrityError
 
+from dispatch.case.messaging import send_entity_update_notification
 from dispatch.case.service import get as get_case
 from dispatch.database.core import DbSession
 from dispatch.database.service import CommonParameters, search_filter_sort_paginate
@@ -18,6 +20,7 @@
 from .flows import recalculate_entity_flow
 from .service import create, delete, get, update
 
+log = logging.getLogger(__name__)
 router = APIRouter()
 
 
@@ -113,6 +116,15 @@ def recalculate(db_session: DbSession, entity_type_id: PrimaryKey, case_id: Prim
         )
         updated_signal_instances.append(updated_signal_instance)
 
+    try:
+        send_entity_update_notification(
+            db_session=db_session,
+            entity_type=entity_type,
+            case=signal_instances[0].case,
+        )
+    except Exception as e:
+        log.warning(f"Failed to send entity update notification: {e}")
+
     return updated_signal_instances