tenseleyflow/loader / 484a89a

+        progress_messages = list(getattr(self.context.session, "messages", []) or [])

+        progress_intent = _build_in_progress_continuation(

+            content=content,

+            dod=dod,

+            project_root=self.context.project_root,

+            messages=progress_messages,

+        )

+        if progress_intent is not None:

+            assistant_message = Message(role=Role.ASSISTANT, content=response_content)

+            self.context.session.append(assistant_message)

+            summary.assistant_messages.append(assistant_message)

+            if (

+                progress_intent.target is not None

+                and continuation_count == 0

+                and _confirmed_output_file_count(

+                    dod,

+                    project_root=self.context.project_root,

+                )

+                == 0

+                and not _recent_concrete_target_prompt(

+                    progress_messages,

+                    target=progress_intent.target,

+                )

+            ):

+                self._append_completion_trace_entry(

+                    summary=summary,

+                    stage="continuation_check",

+                    outcome="continue",

+                    decision_code="in_progress_transition_continue",

+                    decision_summary=(

+                        "continued to let the assistant finish the concrete next "

+                        "planned step without interrupting it yet"

+                    ),

+                )

+                self._record_completion_decision(

+                    summary=summary,

+                    decision_code="in_progress_transition_continue",

+                    decision_summary=(

+                        "continued to let the assistant finish the concrete next "

+                        "planned step without interrupting it yet"

+                    ),

+                )

+                return TurnCompletionDecision(

+                    action=TurnCompletionAction.CONTINUE,

+                    continuation_count=continuation_count + 1,

+                )

+

+            self.context.session.append(

+                Message(role=Role.USER, content=progress_intent.prompt)

+            )

+            self._append_completion_trace_entry(

+                summary=summary,

+                stage="continuation_check",

+                outcome="continue",

+                decision_code="in_progress_transition_continue",

+                decision_summary=(

+                    "continued because the assistant described the next planned step "

+                    "without executing it yet"

+                ),

+            )

+            self._record_completion_decision(

+                summary=summary,

+                decision_code="in_progress_transition_continue",

+                decision_summary=(

+                    "continued because the assistant described the next planned step "

+                    "without executing it yet"

+                ),

+            )

+            return TurnCompletionDecision(

+                action=TurnCompletionAction.CONTINUE,

+                continuation_count=continuation_count + 1,

+            )

+

+@pytest.mark.asyncio

+async def test_turn_completion_prioritizes_missing_artifact_continuation_over_text_loop(

+    temp_dir: Path,

+) -> None:

+    backend = ScriptedBackend()

+    config = non_streaming_config()

+    config.reasoning.completion_check = False

+    agent = Agent(

+        backend=backend,

+        config=config,

+        project_root=temp_dir,

+    )

+    runtime = ConversationRuntime(agent)

+    events = []

+

+    async def capture(event) -> None:

+        events.append(event)

+

+    prepared = await runtime.turn_preparation.prepare(

+        task=(

+            "Create a multi-file nginx guide under ~/Loader/guides/nginx "

+            "with an index and chapter files."

+        ),

+        emit=capture,

+        requested_mode="execute",

+        original_task=None,

+        on_user_question=None,

+    )

+    await runtime.phase_tracker.enter(

+        TurnPhase.ASSISTANT,

+        capture,

+        detail="Requesting assistant response",

+        reason_code="request_assistant_response",

+    )

+

+    implementation_plan = temp_dir / "implementation.md"

+    implementation_plan.write_text(

+        "# Implementation Plan\n\n"

+        "## File Changes\n\n"

+        "1. Create main index.html file:\n"

+        f"   - `{temp_dir / 'index.html'}`\n\n"

+        "2. Create chapter files:\n"

+        f"   - `{temp_dir / 'chapters' / '01-introduction.html'}`\n"

+        f"   - `{temp_dir / 'chapters' / '02-installation.html'}`\n"

+    )

+    chapters_dir = temp_dir / "chapters"

+    chapters_dir.mkdir()

+    (temp_dir / "index.html").write_text("<h1>NGINX Guide</h1>\n")

+    (chapters_dir / "01-introduction.html").write_text("<h1>Intro</h1>\n")

+

+    prepared.definition_of_done.implementation_plan = str(implementation_plan)

+    prepared.definition_of_done.mutating_actions.append("write")

+    prepared.definition_of_done.touched_files.extend(

+        [

+            str(temp_dir / "index.html"),

+            str(chapters_dir / "01-introduction.html"),

+        ]

+    )

+    prepared.definition_of_done.pending_items.append("Create chapter files for nginx guide")

+

+    content = "Let me continue creating the remaining chapter files for the nginx guide:"

+    runtime.context.safeguards.record_response(content)

+    runtime.context.safeguards.record_response(content)

+

+    decision = await runtime.turn_completion.handle_text_response(

+        content=content,

+        response_content=content,

+        task=prepared.task,

+        effective_task=prepared.effective_task,

+        iterations=1,

+        max_iterations=agent.config.max_iterations,

+        actions_taken=[],

+        continuation_count=2,

+        dod=prepared.definition_of_done,

+        emit=capture,

+        summary=prepared.summary,

+        executor=prepared.executor,

+        rollback_plan=prepared.rollback_plan,

+    )

+

+    assert decision.action == TurnCompletionAction.CONTINUE

+    assert prepared.summary.completion_decision_code == "in_progress_transition_continue"

+    assert agent.session.messages[-1].role.value == "user"

+    assert agent.session.messages[-1].content.startswith("[CONTINUE CURRENT STEP]")

+    assert "02-installation.html" in agent.session.messages[-1].content

+    assert not prepared.summary.final_response

+    assert not any(event.type == "error" and "Text loop detected" in event.content for event in events)

+

+