Compare commits
3 commits
6771da634a
...
028195d09c
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
028195d09c | ||
|
|
cc6867d813 | ||
|
|
b84f4aaac1 |
3 changed files with 1 additions and 6 deletions
|
|
@ -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:
|
||||||
|
|
|
||||||
|
|
@ -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:
|
||||||
|
|
|
||||||
|
|
@ -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"])
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue