Compare commits

...

3 commits

3 changed files with 1 additions and 6 deletions

View file

@ -131,10 +131,6 @@ Return ONLY valid JSON (no markdown, no explanation):
} }
``` ```
Valid values for `status`: `"done"`, `"blocked"`.
If status is "blocked", include `"blocked_reason": "..."` and `"analysis": "..."` explaining why the task cannot be planned.
## Blocked Protocol ## Blocked Protocol
If you cannot plan the pipeline (task is completely ambiguous, no information to work with, or explicitly outside the system scope), return this JSON **instead of** the normal output: If you cannot plan the pipeline (task is completely ambiguous, no information to work with, or explicitly outside the system scope), return this JSON **instead of** the normal output:

View file

@ -1800,7 +1800,7 @@ def run_pipeline(
pass pass
else: else:
# Review mode: wait for manual approval # Review mode: wait for manual approval
models.update_task(conn, task_id, status="review") models.update_task(conn, task_id, status="review", execution_mode="review")
# Run post-pipeline hooks (failures don't affect pipeline status) # Run post-pipeline hooks (failures don't affect pipeline status)
try: try:

View file

@ -332,7 +332,6 @@ def format_prompt(context: dict, role: str, prompt_template: str | None = None)
sections.append("") sections.append("")
# Revision context: director's comment + agent's previous output # Revision context: director's comment + agent's previous output
task = context.get("task")
if task and task.get("revise_comment"): if task and task.get("revise_comment"):
sections.append("## Director's revision request:") sections.append("## Director's revision request:")
sections.append(task["revise_comment"]) sections.append(task["revise_comment"])