feat: update changelog for version 0.4.0 with streaming support and new features

Author: tercel

CHANGELOG.md

@@ -6,6 +6,47 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 
+## [0.4.0] - 2026-02-20
+
+### Added
+
+#### Streaming Support
+- **Executor.stream()** - New async generator method for streaming module execution
+  - Implements same 6-step pipeline as `call_async()` (context, safety, lookup, ACL, input validation, middleware before)
+  - Falls back to `call_async()` yielding single chunk for non-streaming modules
+  - For streaming modules, iterates `module.stream()` and yields each chunk
+  - Accumulates chunks via shallow merge for output validation and after-middleware
+  - Full error handling with middleware recovery
+- **ModuleAnnotations.streaming** - New `streaming: bool = False` field to indicate if a module supports streaming execution
+- **Test coverage** - Added 5 comprehensive tests in `test_executor_stream.py`:
+  - Fallback behavior for non-streaming modules
+  - Multi-chunk streaming
+  - Module not found error handling
+  - Before/after middleware integration
+  - Disjoint key accumulation via shallow merge
+
+
+## [0.3.0] - 2026-02-20
+
+### Added
+
+#### Public API Extensions
+- **ErrorCodes** - New `ErrorCodes` class with all framework error code constants; replaces hardcoded error strings
+- **ContextFactory Protocol** - New `ContextFactory` protocol for creating Context from framework-specific requests (e.g., Django, FastAPI)
+- **Registry constants** - Exported `REGISTRY_EVENTS` dict and `MODULE_ID_PATTERN` regex for consistent module ID validation
+- **Executor.from_registry()** - Convenience factory method for creating an Executor from a Registry with optional middlewares, ACL, and config
+
+#### Schema System
+- **Comprehensive schema system** - Full implementation with loading, validation, and export capabilities
+  - Schema loading from JSON/YAML files
+  - Runtime schema validation
+  - Schema export functionality
+
+### Fixed
+- **ErrorCodes class** - Prevent attribute deletion to ensure error code constants remain immutable
+- **Planning documentation** - Updated progress bar style in overview.md
+
+
 ## [0.2.3] - 2026-02-20
 
 ### Added

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "apcore"
-version = "0.3.0"
+version = "0.4.0"
 description = "Schema-driven module development framework for AI-perceivable interfaces"
 readme = "README.md"
 requires-python = ">=3.11"

src/apcore/__init__.py

@@ -61,7 +61,7 @@
     TracingMiddleware,
 )
 
-__version__ = "0.3.0"
+__version__ = "0.4.0"
 
 __all__ = [
     # Core

src/apcore/executor.py

@@ -756,7 +756,11 @@ async def stream(
             # Error handling with middleware recovery
             if executed_middlewares:
                 recovery = await self._execute_on_error_async(
-                    module_id, effective_inputs, exc, ctx, executed_middlewares,
+                    module_id,
+                    effective_inputs,
+                    exc,
+                    ctx,
+                    executed_middlewares,
                 )
                 if recovery is not None:
                     yield recovery

tests/test_executor_stream.py

@@ -47,9 +47,7 @@ def __init__(self) -> None:
     def execute(self, inputs: dict[str, Any], context: Context) -> dict[str, Any]:
         return {"value": inputs["count"]}
 
-    async def stream(
-        self, inputs: dict[str, Any], context: Context
-    ) -> AsyncIterator[dict[str, Any]]:
+    async def stream(self, inputs: dict[str, Any], context: Context) -> AsyncIterator[dict[str, Any]]:
         for i in range(1, inputs["count"] + 1):
             yield {"value": i}
 
@@ -64,9 +62,7 @@ def __init__(self) -> None:
     def execute(self, inputs: dict[str, Any], context: Context) -> dict[str, Any]:
         return {"a": "val_a", "b": "val_b"}
 
-    async def stream(
-        self, inputs: dict[str, Any], context: Context
-    ) -> AsyncIterator[dict[str, Any]]:
+    async def stream(self, inputs: dict[str, Any], context: Context) -> AsyncIterator[dict[str, Any]]:
         yield {"a": "val_a"}
         yield {"b": "val_b"}
 
@@ -138,9 +134,7 @@ def after(
                 log.append("after")
                 return None
 
-        ex = _make_executor(
-            module=mod, module_id="counter", middlewares=[TrackingMiddleware()]
-        )
+        ex = _make_executor(module=mod, module_id="counter", middlewares=[TrackingMiddleware()])
 
         chunks: list[dict[str, Any]] = []
         async for chunk in ex.stream("counter", {"count": 2}):
@@ -166,9 +160,7 @@ def after(
                 after_output = dict(output)
                 return None
 
-        ex = _make_executor(
-            module=mod, module_id="disjoint", middlewares=[CaptureAfter()]
-        )
+        ex = _make_executor(module=mod, module_id="disjoint", middlewares=[CaptureAfter()])
 
         chunks: list[dict[str, Any]] = []
         async for chunk in ex.stream("disjoint", {}):