Keep setup nudges on planned roots

Status	File	+	-
M	`src/loader/runtime/tool_batches.py`	81	30
M	`src/loader/runtime/workflow.py`	20	10
M	`tests/test_tool_batches.py`	19	1
M	`tests/test_workflow.py`	31	0

src/loader/runtime/tool_batches.pymodified

          if next_pending:
              mutation_suffix = ""
              if _todo_is_mutation_step(next_pending):
 -                mutation_suffix = _missing_artifact_resume_suffix(
 -                    missing_artifact,
 +                mutation_suffix = _pending_item_resume_suffix(
 +                    dod,
 +                    next_pending=next_pending,
 +                    missing_artifact=missing_artifact,
                      project_root=self.context.project_root,
                      messages=list(getattr(self.context.session, "messages", []) or []),
+                 )
          mutation_suffix = ""
          if _todo_is_mutation_step(next_pending):
 -            mutation_suffix = _missing_artifact_resume_suffix(
 -                missing_artifact,
 +            mutation_suffix = _pending_item_resume_suffix(
 +                dod,
 +                next_pending=next_pending,
 +                missing_artifact=missing_artifact,
                  project_root=self.context.project_root,
                  messages=list(getattr(self.context.session, "messages", []) or []),
+             )
          return ""
      target, expect_directory = missing_artifact
 +    return _resume_suffix_for_target(
 +        target,
 +        expect_directory=expect_directory,
 +        project_root=project_root,
 +        messages=messages,
 +    )
++
++
 +def _pending_item_resume_suffix(
 +    dod: DefinitionOfDone,
 +    *,
 +    next_pending: str | None,
 +    missing_artifact: tuple[Path, bool] | None,
 +    project_root: Path,
 +    messages: list[Any] | None = None,
 +) -> str:
 +    if next_pending:
 +        pending_target = infer_pending_todo_output_target(
 +            dod,
 +            next_pending,
 +            project_root=project_root,
 +        )
 +        if pending_target is not None and not pending_target.exists():
 +            normalized_target = pending_target.expanduser().resolve(strict=False)
 +            return _resume_suffix_for_target(
 +                normalized_target,
 +                expect_directory=not bool(normalized_target.suffix),
 +                project_root=project_root,
 +                messages=messages,
 +                allow_inferred_child=False,
 +            )
 +    return _missing_artifact_resume_suffix(
 +        missing_artifact,
 +        project_root=project_root,
 +        messages=messages,
 +    )
++
++
 +def _resume_suffix_for_target(
 +    target: Path,
 +    *,
 +    expect_directory: bool,
 +    project_root: Path,
 +    messages: list[Any] | None = None,
 +    allow_inferred_child: bool = True,
 +) -> str:
      label = target.name or str(target)
      if expect_directory and not label.endswith("/"):
          label += "/"
      if expect_directory:
 +        if allow_inferred_child:
              next_output_file, next_output_source = infer_next_output_file(
                  target=target,
                  project_root=project_root,

src/loader/runtime/workflow.pymodified

          project_root=root,
          max_paths=12,
+     )
+-
 -    if candidates:
      planned_files = [
          target
          for target, expect_directory in planned_targets
          for target, expect_directory in planned_targets
          if expect_directory
+     ]
++
 +    if candidates:
          touched_paths = [
              Path(path)
              for path in dod.touched_files
              for directory in planned_directories:
                  return directory / candidate.name
 +    if target_label and _contains_any(target_label, _BROAD_SETUP_HINTS):
 +        for directory in planned_directories:
 +            if not planned_artifact_target_satisfied(
 +                dod=dod,
 +                target=directory,
 +                expect_directory=True,
 +                project_root=root,
 +            ):
 +                return directory
++
      if not target_label:
          return None

tests/test_tool_batches.pymodified

      reference = temp_dir / "fortran" / "chapters" / "01-introduction.html"
      reference.parent.mkdir(parents=True)
      reference.write_text("<h1>Introduction</h1>\n<p>Guide cadence.</p>\n")
 +    nginx_root = temp_dir / "Loader" / "guides" / "nginx"
 +    chapters = nginx_root / "chapters"
 +    implementation_plan = temp_dir / "implementation.md"
 +    implementation_plan.write_text(
 +        "\n".join(
 +            [
 +                "# Implementation Plan",
 +                "",
 +                "## File Changes",
 +                f"- `{chapters}/`",
 +                f"- `{nginx_root / 'index.html'}`",
 +                "",
 +            ]
 +        )
 +    )
      context = build_context(
          temp_dir=temp_dir,
      context.queue_ephemeral_steering_message_callback = ephemeral_messages.append
      runner = ToolBatchRunner(context, DefinitionOfDoneStore(temp_dir))
      dod = create_definition_of_done("Create an equally thorough nginx guide.")
 +    dod.implementation_plan = str(implementation_plan)
      sync_todos_to_definition_of_done(
          dod,
+         [
          for message in persistent_messages
+     )
      assert any(
 -        "stop gathering more reference material and perform the change now" in message
 +        "Resume by creating `chapters/` now." in message
          for message in persistent_messages
+     )
 +    assert all("01-introduction.html" not in message for message in persistent_messages)
 +    assert ephemeral_messages == []
  @pytest.mark.asyncio

tests/test_workflow.pymodified

      effective_pending_todo_items,
      enrich_clarify_brief_with_grounding,
      extract_verification_commands_from_markdown,
 +    infer_pending_todo_output_target,
      merge_refreshed_todos_with_existing_scope,
      preserve_task_grounded_acceptance_criteria,
      reconcile_aggregate_completion_steps,
      assert "Create index.html for nginx guide" in dod.pending_items
 +def test_infer_pending_todo_output_target_maps_broad_setup_to_planned_directory(
 +    tmp_path: Path,
 +) -> None:
 +    dod = create_definition_of_done("Create a multi-file nginx guide.")
 +    nginx_root = tmp_path / "Loader" / "guides" / "nginx"
 +    chapters = nginx_root / "chapters"
 +    implementation_plan = tmp_path / "implementation.md"
 +    implementation_plan.write_text(
 +        "\n".join(
 +            [
 +                "# Implementation Plan",
 +                "",
 +                "## File Changes",
 +                f"- `{chapters}/`",
 +                f"- `{nginx_root / 'index.html'}`",
 +                "",
 +            ]
 +        )
 +    )
 +    dod.implementation_plan = str(implementation_plan)
++
 +    target = infer_pending_todo_output_target(
 +        dod,
 +        "Create the nginx directory structure",
 +        project_root=tmp_path,
 +    )
++
 +    assert target == chapters.resolve(strict=False)
++
++
  def test_advance_todos_from_tool_call_does_not_complete_content_study_from_root_index_read() -> None:
      dod = create_definition_of_done("Create a multi-file nginx guide.")
      sync_todos_to_definition_of_done(

tenseleyflow/loader / `938dadc`

4 changed files