Merge pull request #135 from shenald-dev/jules/apex-forge-maintainability-2430603911627901522

Maintainability & DX: Root Exports and Dynamic API Versioning

Author: shenald-dev

CHANGELOG.md

@@ -335,3 +335,7 @@ All notable changes to this project will be documented in this file.
 
 ## [0.1.31] - 2026-05-31
 * **Bugfix:** Auto-resolved git merge conflict syntax errors, ensuring safe dependency fetching logic and proper code indentations.
+
+## 2026-06-01 - v0.1.32
+
+* **Maintainability:** Exported core engine primitives at package root for better DX, and dynamically resolved FastAPI app version to prevent drift.

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "catalyst"
-version = "0.1.31"
+version = "0.1.32"
 description = "High-performance workflow engine for complex pipelines. Parallel DAG execution, <1s sorts, zero bloat."
 authors = [    { name = "shenald-dev", email = "bot@shenald.dev" }
 ]

src/catalyst/__init__.py

@@ -0,0 +1,3 @@
+from .domain.engine import WorkflowEngine, TaskError
+
+__all__ = ["WorkflowEngine", "TaskError"]

src/catalyst/domain/engine.py

@@ -73,11 +73,15 @@ def add_task(
         self.tasks[name] = func
         self._timeouts[name] = timeout
 
+        # Check if the function is asynchronous, correctly unwrapping partials
+        # and checking __call__ for async callable objects.
         is_async = inspect.iscoroutinefunction(func)
         if not is_async:
             base_func = func
             while isinstance(base_func, functools.partial):
                 base_func = base_func.func
+            # inspect.iscoroutinefunction naturally handles functions, methods, and builtins.
+            # Only objects implementing __call__ might incorrectly return False.
             if not isinstance(
                 base_func,
                 (types.FunctionType, types.MethodType, types.BuiltinFunctionType),

src/catalyst/presentation/api/main.py

@@ -2,14 +2,22 @@
 
 from fastapi import FastAPI
 from pydantic import BaseModel
-from catalyst.domain.engine import TaskError, WorkflowEngine
+from importlib.metadata import version, PackageNotFoundError
+
+try:
+    __version__ = version("catalyst")
+except PackageNotFoundError:
+    __version__ = "0.0.0-dev"
+
+from catalyst import TaskError, WorkflowEngine
 
 app = FastAPI(
     title="Catalyst Workflow API",
     description="High-performance DAG execution engine interface",
-    version="0.1.29",
+    version=__version__,
 )
 
+
 class StatusResponse(BaseModel):
     status: str
     message: str
@@ -51,4 +59,4 @@ def failing_task() -> str:
         else:
             serializable_results[task_name] = result
 
-    return {"status": "success", "results": serializable_results}
+    return {"status": "success", "results": serializable_results}