- Add checkpoint creation feature tests (BDD)
- Implement step definitions for checkpoint creation scenarios
- Support manual checkpoint creation via CheckpointService
- Support automatic checkpoint creation at configurable intervals
- Implement checkpoint retention policy enforcement
- Add checkpoint persistence to database
- Integrate checkpoint creation with plan lifecycle
- Emit CHECKPOINT_CREATED domain events on checkpoint creation
- Fix ambiguous step definition in invariant enforcement tests

@@ -0,0 +1,134 @@
+@phase2 @checkpoint @creation

@@ -0,0 +1,458 @@
+"""Step definitions for checkpoint creation feature (part 1 of 2).

@@ -0,0 +29,4 @@
+    context: object, processing_state: str
+) -> None:
+    """Create a plan in execute phase with a specific processing state."""
+    from ulid import ULID

@@ -0,0 +34,4 @@
+    context.plan_id = str(ULID())
+    context.sandbox_path = tempfile.mkdtemp()
+    subprocess.run(
+        ["git", "init"], cwd=context.sandbox_path, check=True, capture_output=True

@@ -0,0 +160,4 @@
+
+@given("a plan with max_checkpoints set to {max_count:d}")
+def step_plan_with_max_checkpoints(context: object, max_count: int) -> None:
+    """Create a plan with max_checkpoints set and inject retention policy."""

@@ -0,0 +1,223 @@
+"""Step definitions for checkpoint creation feature (part 2 of 2).

@@ -0,0 +1,495 @@
+"""Step definitions for checkpoint creation feature (part 1 of 2).

@@ -0,0 +286,4 @@
+        context.checkpoint_service.create_checkpoint(
+            plan_id=plan_id,
+            sandbox_ref="/nonexistent/path",
+        )

@@ -0,0 +1,223 @@
+"""Step definitions for checkpoint creation feature (part 2 of 2).

@@ -0,0 +1,495 @@
+"""Step definitions for checkpoint creation feature (part 1 of 2).

@@ -0,0 +90,4 @@
+    context.error = None
+
+
+@given("a file exists in the sandbox with content {content}")

@@ -0,0 +276,4 @@
+        context.checkpoints = []
+
+
+@when("I attempt to create a checkpoint for non-existent plan {plan_id}")

@@ -0,0 +276,4 @@
+        context.checkpoints = []
+
+
+@when('I attempt to create a checkpoint for non-existent plan "{plan_id}"')