diff --git a/src/cleveragents/application/services/correction_service.py b/src/cleveragents/application/services/correction_service.py
index 46f3e9448..54b8c49b4 100644
--- a/src/cleveragents/application/services/correction_service.py
+++ b/src/cleveragents/application/services/correction_service.py
@@ -223,15 +223,6 @@ class CorrectionService:
             correction_id, request, result, attempt.attempt_id
         )
         return result
-        logger.info(
-            "correction.append_executed",
-            correction_id=correction_id,
-            status=result.status,
-        )
-        self._emit_correction_applied(
-            correction_id, request, result, attempt.attempt_id
-        )
-        return result
 
     def execute_correction(self, correction_id: str,
         decision_tree: dict[str, list[str]] | None = None,
diff --git a/src/cleveragents/cli/commands/plan.py b/src/cleveragents/cli/commands/plan.py
index a9e3c6e9d..7419d4666 100644
--- a/src/cleveragents/cli/commands/plan.py
+++ b/src/cleveragents/cli/commands/plan.py
@@ -789,7 +789,7 @@ async def _tell_streaming(
                 description,
                 name,
                 actor=actor,
-            ):  # type: ignore[arg-type]
+            ):
                 # Extract node name from event
                 for key in event:
                     if key != "__end__" and key in node_names: