fix(tests): handle new context_create fixture cases and portable fixture paths

- Add elif branches for distributed_cancel_token_post_deserialize_null
  and distributed_global_deadline_post_deserialize_null in
  test_context_create_unified_signature (both assert null after deserialize)
- Replace hardcoded absolute paths in test_v022_event_delivery.py and
  test_v022_registry_ordering.py with APCORE_SPEC_REPO env-var / sibling
  directory discovery (mirrors test_conformance.py discovery logic)

Signed-off-by: tercel <tercel.yi@gmail.com>

Author: tercel

examples/pipeline_demo.py

@@ -44,17 +44,17 @@
 
 # Per-step roles, used by TracingMiddleware to narrate the pipeline.
 STEP_ROLES: dict[str, str] = {
-    "context_creation":  "create execution context, set global deadline",
-    "call_chain_guard":  "check call depth & repeat limits",
-    "module_lookup":     "resolve module from registry",
-    "acl_check":         "enforce access control (default-deny)",
-    "approval_gate":     "human approval gate (if required)",
+    "context_creation": "create execution context, set global deadline",
+    "call_chain_guard": "check call depth & repeat limits",
+    "module_lookup": "resolve module from registry",
+    "acl_check": "enforce access control (default-deny)",
+    "approval_gate": "human approval gate (if required)",
     "middleware_before": "run before-middleware chain (in order)",
-    "input_validation":  "validate inputs against schema",
-    "execute":           "invoke the module",
+    "input_validation": "validate inputs against schema",
+    "execute": "invoke the module",
     "output_validation": "validate output against schema",
-    "middleware_after":  "run after-middleware chain (reverse order)",
-    "return_result":     "finalize and return output",
+    "middleware_after": "run after-middleware chain (reverse order)",
+    "return_result": "finalize and return output",
 }
 
 
@@ -80,16 +80,12 @@ def before_step(self, step_name: str, state: PipelineState) -> None:
             role = "CUSTOM step inserted via insert_after / replace"
         print(f"  {label} {step_name:<19} — {role}")
 
-    def after_step(
-        self, step_name: str, state: PipelineState, result: StepResult
-    ) -> None:
+    def after_step(self, step_name: str, state: PipelineState, result: StepResult) -> None:
         elapsed_ms = (time.perf_counter() - self._starts.pop(step_name, time.perf_counter())) * 1000
         detail = self._summarize(step_name, state.context, result)
         print(f"          ✓ {elapsed_ms:>6.2f} ms · {detail}")
 
-    def on_step_error(
-        self, step_name: str, state: PipelineState, error: Exception
-    ) -> None:
+    def on_step_error(self, step_name: str, state: PipelineState, error: Exception) -> None:
         print(f"          ✗ {type(error).__name__}: {error}")
         # Returning None lets the original exception propagate.
 
@@ -177,8 +173,7 @@ def add(a: int, b: int) -> int:
     banner("Section 3: Orchestration — insert_after + replace")
     strategy.insert_after("output_validation", AuditLogStep())
     custom = [n for n in strategy.step_names() if n not in CANONICAL_STEPS]
-    print(f"after insert_after: 11 standard + {len(custom)} custom = "
-          f"{len(strategy.steps)} steps")
+    print(f"after insert_after: 11 standard + {len(custom)} custom = " f"{len(strategy.steps)} steps")
     for i, name in enumerate(strategy.step_names(), start=1):
         marker = "  ← CUSTOM (inserted)" if name not in CANONICAL_STEPS else ""
         print(f"  {i:>2}. {name}{marker}")
@@ -187,8 +182,10 @@ def add(a: int, b: int) -> int:
     client.call("math.add", {"a": 2, "b": 3})
 
     strategy.replace("audit_log", QuietAuditLogStep())
-    print(f"\nafter replace: {len(strategy.steps)} steps "
-          f"(audit_log still at index {strategy.step_names().index('audit_log')})")
+    print(
+        f"\nafter replace: {len(strategy.steps)} steps "
+        f"(audit_log still at index {strategy.step_names().index('audit_log')})"
+    )
 
     print("\ncalling with the quiet replacement:")
     client.call("math.add", {"a": 7, "b": 9})

src/apcore/context.py

@@ -133,9 +133,7 @@ def _bind_executor(self, executor: Any) -> None:
             # Imported lazily to avoid a circular import (errors -> context).
             from apcore.errors import ContextBindingError
 
-            raise ContextBindingError(
-                "Context already bound to a different Executor instance"
-            )
+            raise ContextBindingError("Context already bound to a different Executor instance")
         # else: same executor instance, noop.
 
     def serialize(self) -> dict[str, Any]:

tests/conformance/test_v022_event_delivery.py

@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 import json
+import os
 import re
 from pathlib import Path
 
@@ -11,11 +12,17 @@
 from apcore.events.emitter import ApCoreEvent, EventEmitter, _DLQ_EVENT_TYPE
 from apcore.events.retry import EventRetryConfig
 
-_FIXTURE_PATH = Path("/Users/tercel/WorkSpace/aipartnerup/apcore/conformance/fixtures/event_delivery_semantics.json")
+
+def _fixture_path() -> Path:
+    env = os.environ.get("APCORE_SPEC_REPO")
+    if env:
+        return Path(env) / "conformance" / "fixtures" / "event_delivery_semantics.json"
+    repo_root = Path(__file__).resolve().parent.parent.parent
+    return repo_root.parent / "apcore" / "conformance" / "fixtures" / "event_delivery_semantics.json"
 
 
 def _load_fixture() -> dict:
-    with _FIXTURE_PATH.open() as f:
+    with _fixture_path().open() as f:
         return json.load(f)
 
 

tests/conformance/test_v022_registry_ordering.py

@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 import json
+import os
 import threading
 import time
 from pathlib import Path
@@ -14,11 +15,17 @@
 from apcore.events.emitter import ApCoreEvent, EventEmitter
 from apcore.registry import Registry
 
-_FIXTURE_PATH = Path("/Users/tercel/WorkSpace/aipartnerup/apcore/conformance/fixtures/registry_load_ordering.json")
+
+def _fixture_path() -> Path:
+    env = os.environ.get("APCORE_SPEC_REPO")
+    if env:
+        return Path(env) / "conformance" / "fixtures" / "registry_load_ordering.json"
+    repo_root = Path(__file__).resolve().parent.parent.parent
+    return repo_root.parent / "apcore" / "conformance" / "fixtures" / "registry_load_ordering.json"
 
 
 def _load_fixture() -> dict:
-    with _FIXTURE_PATH.open() as f:
+    with _fixture_path().open() as f:
         return json.load(f)
 
 

tests/test_conformance.py

@@ -1839,9 +1839,37 @@ def test_context_create_unified_signature(case: dict[str, Any]) -> None:
         assert carried is not None and len(carried) == len(tp_in["tracestate"])
         # And the signature does NOT expose a separate tracestate parameter.
         params = _inspect.signature(Context.create).parameters
-        assert "tracestate" not in params, (
-            "tracestate MUST live inside TraceParent — no separate Context.create parameter"
-        )
+        assert (
+            "tracestate" not in params
+        ), "tracestate MUST live inside TraceParent — no separate Context.create parameter"
+
+    elif case_id == "distributed_cancel_token_post_deserialize_null":
+        # Negative invariant: cancel_token MUST NOT serialize. A deserialized
+        # Context on a remote node has cancel_token == None (PROTOCOL_SPEC §5.7).
+        serialized: dict[str, Any] = {
+            "_context_version": 1,
+            "trace_id": "4bf92f3577b34da6a3ce929d0e0e4736",
+            "caller_id": "remote.caller",
+            "call_chain": ["remote.caller"],
+            "identity": None,
+            "data": {},
+        }
+        restored = Context.deserialize(serialized)
+        assert restored.cancel_token is None, "cancel_token MUST be null after deserialization"
+
+    elif case_id == "distributed_global_deadline_post_deserialize_null":
+        # Negative invariant: global_deadline MUST NOT serialize. A deserialized
+        # Context on a remote node has global_deadline == None (PROTOCOL_SPEC §5.7).
+        serialized = {
+            "_context_version": 1,
+            "trace_id": "4bf92f3577b34da6a3ce929d0e0e4736",
+            "caller_id": "remote.caller",
+            "call_chain": [],
+            "identity": None,
+            "data": {},
+        }
+        restored = Context.deserialize(serialized)
+        assert restored.global_deadline is None, "global_deadline MUST be null after deserialization"
 
     else:
         pytest.fail(f"Unknown context_create fixture case id: {case_id!r}")